Graphorin API reference v0.8.0
Graphorin API reference / @graphorin/channels / testkit / LoopbackAdapter
Interface: LoopbackAdapter
Defined in: packages/channels/src/testkit/loopback-adapter.ts:38
The in-memory loopback adapter: a full ChannelAdapter whose transport is the test itself. Tests inject() inbound messages and read deliveries for what the gateway sent back.
Stable
Extends
Properties
| Property | Modifier | Type | Description | Inherited from | Defined in |
|---|---|---|---|---|---|
capabilities | readonly | ChannelCapabilities | - | ChannelAdapter.capabilities | packages/channels/src/spi.ts:216 |
deliveries | readonly | readonly DeliveryPayload[] | Every payload delivered so far, in order (post-sanitization). | - | packages/channels/src/testkit/loopback-adapter.ts:42 |
id | readonly | string | Stable channel id; becomes ChannelIdentity.channelId on inbound. | ChannelAdapter.id | packages/channels/src/spi.ts:215 |
started | readonly | boolean | - | - | packages/channels/src/testkit/loopback-adapter.ts:43 |
Methods
deliver()
deliver(payload): Promise<DeliveryReceipt>;Defined in: packages/channels/src/spi.ts:225
Deliver one outbound payload. Throws ChannelDeliveryError after in-call retries are exhausted (D-14: no durable outbox).
Parameters
| Parameter | Type |
|---|---|
payload | DeliveryPayload |
Returns
Promise<DeliveryReceipt>
Inherited from
failNextDeliver()
failNextDeliver(): void;Defined in: packages/channels/src/testkit/loopback-adapter.ts:45
Make the next deliver call throw a retryable ChannelDeliveryError.
Returns
void
inject()
inject(input): Promise<InboundAcceptance>;Defined in: packages/channels/src/testkit/loopback-adapter.ts:40
Push one inbound message through the gateway (must be started).
Parameters
| Parameter | Type |
|---|---|
input | LoopbackInboundInput |
Returns
Promise<InboundAcceptance>
start()
start(ctx): Promise<void>;Defined in: packages/channels/src/spi.ts:218
Subscribe / start polling. Resolves once the adapter is receiving.
Parameters
| Parameter | Type |
|---|---|
ctx | ChannelRuntimeContext |
Returns
Promise<void>
Inherited from
stop()
stop(): Promise<void>;Defined in: packages/channels/src/spi.ts:220
Stop receiving; idempotent.
Returns
Promise<void>