StreamTransformer subscriptionTransformer()

in lib/src/stream_subscription_transformer.dart [30:47]

• 18 lines of code
• 1 McCabe index (conditional complexity)

StreamTransformer<T, T> subscriptionTransformer<T>(
    {Future Function(StreamSubscription<T>)? handleCancel,
    void Function(StreamSubscription<T>)? handlePause,
    void Function(StreamSubscription<T>)? handleResume}) {
  return StreamTransformer((stream, cancelOnError) {
    return _TransformedSubscription(
        stream.listen(null, cancelOnError: cancelOnError),
        handleCancel ?? (inner) => inner.cancel(),
        handlePause ??
            (inner) {
              inner.pause();
            },
        handleResume ??
            (inner) {
              inner.resume();
            });
  });
}