ByteStream constructor

ByteStream([
  1. Stream<List<int>>? stream,
  2. List<int>? buffer
])

Implementation

ByteStream([Stream<List<int>>? stream, List<int>? buffer]) {
  _stream = stream ?? empty;
  if (stream != null) {
    _stream.listen((event) {
      _currentList.addAll(event);
    }, onDone: () {
      _closed = true;
    });
  } else {
    _closed = true;
  }
  if (buffer != null) {
    _currentList.addAll(buffer);
  }
}