Creates an in-memory queue connector using a simple message store.

In-memory queue connector.

Options for negative acknowledgment.

Queue wrapper with Task/Stream semantics for error-tolerant message processing.

Acknowledgment operation failed.

Queue adapter interface for low-level queue operations.

Connection close operation failed.

Connection establishment failed.

Connector that produces connected QueueAdapter instances.

Consumer handler failed unexpectedly.

Base error for all queue-related failures.

Message exceeded maximum delivery attempts.

Queue adapter interface for queue-agnostic operations.

Negative acknowledgment operation failed.

Queue configuration options.

Message receive operation failed.

Message send operation failed.

Options for sending a message with delay or scheduling.

The entry point for creating a Stream. Wraps an async generator so that yielded values become success results and any thrown error becomes a single error result.

A TypeScript library that provides a powerful and flexible way to handle errors in asynchronous streams. It allows you to collect and manage errors alongside successful values in a stream, enabling you to process data while gracefully handling any issues that may arise.

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).

A single async task with error-aware utilities like retries and timeouts.