Type Alias SubjectOptions<In, Out>

SubjectOptions: SubjectOptionsBase<In, Out> & SubjectControllableOptions<In> & SubjectForkableOptions<
Out,
>

A Subject is a combination of a :class and a :class giving the developer the ability to both queue items and fork the stream from the same object.

Type Parameters

In
Out

Example

const subject = new Subject<number>()

subject.enqueue(1)
subject.enqueue(2)
subject.enqueue(3)

subject.fork().pipeTo(write(chunk => console.info(chunk)))