DwStreamRecording<T> constructor

DwStreamRecording<T>(
  1. Stream<T> stream
)

Implementation

DwStreamRecording(Stream<T> stream) {
  _subscription = stream.listen(
    _values.add,
    onError: errors.add,
    onDone: () => _done = true,
  );
}