Object.StreamEmitter (object v0.1.2)

Stream emitter that generates ideas with configurable rate and quality. Respects backpressure from connected processors.

Summary

Types

t()

Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

connect(emitter, processor)

disable(emitter)

enable(emitter)

get_stats(emitter)

set_rate(emitter, rate)

start_link(opts \\ [])

Types

t()

@type t() :: %Object.StreamEmitter{
  enabled: boolean(),
  processor: pid() | nil,
  quality: float(),
  rate: float(),
  stats: map(),
  variability: float()
}

Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

connect(emitter, processor)