StreamAdapter.subscribe - queue documentation

method StreamAdapter.subscribe



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

Type Parameters



queue: string

optional



options: { signal?: AbortSignal; prefetch?: number;  }

AsyncIterable<QueueMessage<T>>

import { type StreamAdapter } from ".";