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