provideInputStream method

@override TResultStream<TData> provideInputStream()

Subclasses return the upstream input that feeds this service. Called once per restartStream / init. May return a single-subscription or broadcast stream.

Implementation

@override
TResultStream<TData> provideInputStream() =>
    _pollerStream<TData>(onPoll, providePollingInterval());