Crate janus

Source
Expand description

§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 Publisher or Subscriber.
Message
Provides a generic abstraction over a message.
Publisher
Publishes Messages via a sink.
Statuser
Checks the status of an adapter.
Subscriber
Produces a stream of Messages.

Functions§

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