Module tokio_zmq::prelude[][src]

Provide useful types and traits for working with Tokio ZMQ.

Traits

AsSocket

The AsSocket trait is implemented for all wrapper types. This makes implementing other traits a matter of saying a given type implements them.

ControlHandler

The ControlHandler trait is used to impose stopping rules for streams that otherwise would continue to create multiparts.

Controllable

This trait is implemented by all Streams with Item = Multipart and Error = Error, it provides the ability to control when the stream stops based on the content of another stream.

EndHandler

The EndHandler trait is used to impose stopping rules for streams that otherwise would continue to create multiparts.

SinkSocket

This trait provides the basic Sink support for ZeroMQ Sockets. It depends on AsSocket and provides the send and sink methods.

SinkStreamSocket

This trait is provided for sockets that implement both Sync and Stream

StreamSocket

This trait provides the basic Stream support for ZeroMQ Sockets. It depends on AsSocket, but provides implementations for sink and recv.

WithEndHandler

This trait is provided to allow for ending a stream based on a Multipart message it receives.

WithTimeout

This trait allows adding a timeout to any stream with Error = Error.