Transaction<T> constructor

Transaction<T>(
  1. Stream<Uint8List> stream,
  2. DisposableStreamTransformer<Uint8List, T> transformer
)

Transaction Constructor, pass it the untransformed input stream and the transformer to work on the stream.

Implementation

Transaction(Stream<Uint8List> stream, DisposableStreamTransformer<Uint8List, T> transformer)
    : this.stream = stream.transform(transformer),
      _transformer = transformer {
  _queue = StreamQueue<T>(this.stream);
}