[−][src]Crate janus

Janus

Janus is a thin abstraction for synchronous/asynchronous messages publishing and consumption.

Wraps a message with a channel for sending acknowledgments.

AckHandler	Produces a stream of acknowledgments from an associated `Publisher` or `Subscriber`.
Message	Provides a generic abstraction over a message.
Publisher	Publishes `Message`s via a sink.
Statuser	Checks the status of an adapter.
Subscriber	Produces a stream of `Message`s.

A convenience function to continuously processes acks until an error is encountered.