Interface MockSource<T>

An Emitter with a ready() method, that only supports a single active subscriber. (Useful for testing stream operators and sinks.)

Created using mockSource().

interface MockSource<T> {
    end: (() => void);
    ready: Backpressure;
    source: Source<T>;
    throw: ((e: any) => void);
    (val: T): void;
}

MockSource(val: T): void
Call the emitter to emit events on its .source
Parameters
- val: T
Returns void
- Defined in src/sources.ts:233

Properties

end: (() => void)

Close all current subscribers' connections

source: Source<T>

An event source that receives the events

throw: ((e: any) => void)

Close all current subscribers' connections with an error