Type Alias UpstreamOptions<In>

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

Properties

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