interface StreamAdapter
extends QueueAdapter

Extended adapter interface for broker-native streaming. Implement this if your broker has push-based message consumption (e.g., RabbitMQ channels, Kafka consumer groups, SQS long polling).

Methods

subscribe<T>(
queue: string,
options?: { signal?: AbortSignal; prefetch?: number; },
): AsyncIterable<QueueMessage<T>>

Usage

import { type StreamAdapter } from ".";