[−][src]Crate janus
Janus
Janus is a thin abstraction for synchronous/asynchronous messages publishing and consumption.
Structs
AckMessage | Wraps a message with a channel for sending acknowledgments. |
Traits
AckHandler | Produces a stream of acknowledgments from an associated |
Message | Provides a generic abstraction over a message. |
Publisher | Publishes |
Statuser | Checks the status of an adapter. |
Subscriber | Produces a stream of |
Functions
noop_ack_handler | A convenience function to continuously processes acks until an error is encountered. |