Type Alias UpstreamOptions<In>

UpstreamOptions: {
    debugLabel: string;
    disposeIfSourceDone: boolean;
    lazy: Lazy;
    onDispose: (reason: string) => void;
    onStart: () => void;
    onStop: () => void;
    onValue: (v: In) => void;
}

Type Parameters

Type declaration

debugLabel: string
disposeIfSourceDone: boolean
If true (default), we dispose the underlying stream if the upstream closes. This happens after onStop() is called.
lazy: Lazy
onDispose: (reason: string) => void
onStart: () => void
Called just before we subscribe to source
onStop: () => void
Called after we unsubscribe from source
onValue: (v: In) => void

Type Alias UpstreamOptions<In>

Type Parameters

Type declaration

debugLabel: string

disposeIfSourceDone: boolean

lazy: Lazy

onDispose: (reason: string) => void

onStart: () => void

onStop: () => void

onValue: (v: In) => void

Settings