Adap.Stream.Emitter behaviour

Source

Summary

next(emitter, n, emit_mod)
start!(elems, sink)

Functions

next(emitter, n, emit_mod)
Source
start!(elems, sink)
Source

Callbacks

do_emit/2

Specs:

  • do_emit(sink :: pid, elem :: term) :: :ok
Source