Interface PushObserver<T>

Callbacks supplied to a push producer for one subscription.

interface PushObserver<T> {
    signal: AbortSignal;
    complete(): void;
    error(reason: unknown): void;
    next(value: T): boolean;
}

Type Parameters

T

Index

Properties

Methods

complete error next

Properties

`Readonly`signal

signal: AbortSignal

Aborts when the consumer stops the subscription.

Methods

complete

complete(): void

Ends production; buffered values are delivered before completion.

Returns void

error

error(reason: unknown): void
Fails the execution immediately, discarding buffered values.
Parameters
- reason: unknown
Returns void

next

next(value: T): boolean
Returns false when this value is rejected or the subscription has ended. Reports acceptance before onDrop runs: drop-oldest returns true even if the hook subsequently drops that value, fails, or cancels the execution.
Parameters
- value: T
Returns boolean