provideInputStream abstract method

Stream<Result<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

Stream<Result<TData>> provideInputStream();