DelegatingStreamSubscription<
    Create delegating subscription forwarding calls to sourceSubscription.
Implementation
DelegatingStreamSubscription(StreamSubscription<T> sourceSubscription)
    : _source = sourceSubscription;