Class BufferedObserver<T>

Type parameters

T

Hierarchy

Observer<T>
- BufferedObserver

Implements

IObserver<T>

Index

Constructors

constructor

Properties

Accessors

Methods

Constructors

constructor

new BufferedObserver(): BufferedObserver

Overrides Observer.constructor
- Defined in observer.ts:56
Returns BufferedObserver

Properties

Private _done

_done: boolean = false

Private _resultQueue

_resultQueue: Optional<IteratorResult<T>>[] = []

Private _started

_started: boolean = false

Private _thrownError

_thrownError: Error | undefined

Private _waitingError

_waitingError: function[] = []

Private _waitingNext

_waitingNext: function[] = []

Accessors

done

get done(): boolean

- Defined in observer.ts:51
Returns boolean

started

get started(): boolean

- Defined in observer.ts:54
Returns boolean

thrownError

get thrownError(): undefined | Error

- Defined in observer.ts:48
Returns undefined | Error

Methods

next

next(value: T): MaybePromise<void>

Implementation of IObserver.next

Inherited from Observer.next
- Defined in observer.ts:20
Parameters
- value: T
Returns MaybePromise<void>

return

return(): MaybePromise<void>

Implementation of IObserver.return

Inherited from Observer.return
- Defined in observer.ts:24
Returns MaybePromise<void>

throw

throw(error: Error): MaybePromise<void>

Implementation of IObserver.throw

Inherited from Observer.throw
- Defined in observer.ts:30
Parameters
- error: Error
Returns MaybePromise<void>

wait

wait(): Promise<IteratorResult<T>>

- Defined in observer.ts:93
Returns Promise<IteratorResult<T>>

Generated using TypeDoc