@epikodelabs/streamix

---

@epikodelabs/streamix / Subject

Type Alias: Subject<T>

Subject<T> = Stream<T, T> & object

Defined in: projects/libraries/streamix/src/lib/subjects/subject.ts:23

Subject is a hot, multicast stream that allows imperatively pushing values with next, signalling completion with complete, or errors with error. It implements Stream<T> and exposes the current value via the value getter when available.

Type Declaration

next()

next(value): void

Parameters

value

T

Returns

void

complete()

complete(): void

Returns

void

error()

error(err): void

Parameters

err

any

Returns

void

completed()

completed(): boolean

Returns

boolean

value

Get Signature

get value(): T | undefined

Returns

T | undefined

subscribe()

Call Signature

subscribe(callback): Subscription

Parameters

callback

(value) => any

Returns

Subscription

Call Signature

subscribe(receiver): Subscription

Parameters

receiver

Receiver<T>

Returns

Subscription

Call Signature

subscribe(): Subscription

Returns

Subscription

Call Signature

subscribe(callbackOrReceiver?): Subscription

Parameters

callbackOrReceiver?

Receiver<T> | (value) => any

Returns

Subscription

Type Parameters

T

T = any