WritableWrap<T, U> extension

on

• BeaconWrapper<T, U>

Methods

ingest(Stream<T> source, {void then(T)?, T? initialValue}) → void

Available on BeaconWrapper<T, U>, provided by the WritableWrap extension

Injest a Stream and add all values emitted from it to this beacon

wrap<V>(ReadableBeacon<V> target, {void then(V)?, bool disposeTogether = false, bool startNow = true}) → void

Available on BeaconWrapper<T, U>, provided by the WritableWrap extension

Wraps a ReadableBeacon and comsume its values