onDone<T> method

Stream<T> onDone<T>(
  1. Stream<T> stream,
  2. void onDone()
)

Implementation

Stream<T> onDone<T>(Stream<T> stream, void onDone()) {
  return stream.transform(
    StreamTransformer.fromHandlers(
      handleDone: (sink) {
        sink.close();
        onDone();
      },
    ),
  );
}