extractAsync method

Future<Uint8List> extractAsync()

Extract ByteBuffer from this stream.

Implementation

Future<Uint8List> extractAsync() {
  var completer = Completer<Uint8List>();
  var sink = ByteConversionSink.withCallback((elements) {
    final value = Uint8List.fromList(elements);
    completer.complete(value);
  });
  listen((data) => sink.add(data),
      onError: completer.completeError,
      onDone: sink.close,
      cancelOnError: true);
  return completer.future;
}