processStream function

Stream<StreamUpdate> processStream(
  1. Stream<List<int>> byteStream
)

Convenience: process a byte stream and yield StreamUpdates directly.

Implementation

Stream<StreamUpdate> processStream(Stream<List<int>> byteStream) async* {
  final (stream, _) = processStreamWithAssembler(byteStream);
  yield* stream;
}