stream<T> static method

StreamBeacon<T> stream<T>(Stream<T> stream, { bool cancelOnError = false, })

Creates a StreamBeacon from a given stream. This beacon updates its value based on the stream's emitted values.

Example:

var myStream = Stream.periodic(Duration(seconds: 1), (i) => i);
var myBeacon = Beacon.stream(myStream);
myBeacon.subscribe((value) {
  print(value); // Outputs the stream's emitted values
});

Implementation

static StreamBeacon<T> stream<T>(
  Stream<T> stream, {
  bool cancelOnError = false,
}) {
  return StreamBeacon<T>(
    stream,
    cancelOnError: cancelOnError,
  );
}