PendingExchange

Defined in: packages/net-core/src/pending-exchange.ts:24

One outstanding request awaiting its response frames.

Created by a session and held by an ExchangeRegistry until it completes, is abandoned, or the connection fails.

Type Parameters

In

In

Constructors

Constructor

new PendingExchange<In>(accept, resolve, reject, onBody?): PendingExchange<In>

Defined in: packages/net-core/src/pending-exchange.ts:38

Parameters

accept

ExchangeAccept<In>

resolve

(frames) => void

reject

(error) => void

onBody?

(frame, body) => void

Returns

PendingExchange<In>

Properties

accept

readonly accept: ExchangeAccept<In>

Defined in: packages/net-core/src/pending-exchange.ts:39

---

frames

readonly frames: In[] = []

Defined in: packages/net-core/src/pending-exchange.ts:26

Frames accepted so far, in arrival order.

---

onBody?

readonly optional onBody?: (frame, body) => void

Defined in: packages/net-core/src/pending-exchange.ts:42

Parameters

frame

In

body

ReadableStream<Uint8Array<ArrayBufferLike>>

Returns

void

---

orphaned

orphaned: boolean = false

Defined in: packages/net-core/src/pending-exchange.ts:34

Set when the caller abandoned the exchange under the discard policy.

The exchange stays registered so it can absorb the response that is still in flight, but its result is thrown away instead of delivered.

Accessors

isSettled

Get Signature

get isSettled(): boolean

Defined in: packages/net-core/src/pending-exchange.ts:46

Whether this exchange has already resolved or rejected.

Returns

boolean

Methods

complete()

complete(): void

Defined in: packages/net-core/src/pending-exchange.ts:51

Deliver the collected frames, unless the exchange was orphaned.

Returns

void

---

fail()

fail(error): void

Defined in: packages/net-core/src/pending-exchange.ts:66

Fail the exchange.

Parameters

error

Error

The reason to reject with.

Returns

void