Non-blocking streaming

Built on top of fs2 streaming, no blocking, no waste.

AMQP compliant

Implements AMQP 0.9.1 and RabbitMQ protocol extensions, supports all of the RabbitMQ features.

Purely functional

Fully referential transparent, no exceptions or runtime reflection and integration with cats-effect for polymorphic effect handling.

Pure scala

Implemented from scratch in scala, to improve ergonomics and integration

Cross platform

Supports all scala platforms, JVM, JS and Native