[][src]Module futures_zmq::prelude

Provide useful types and traits for working with Futures ZMQ.

Traits

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

HasBuilder

This trait is implemented by all socket types to allow custom builders to be created

IntoInnerSocket

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

SinkSocket

This trait provides the basic Sink support for ZeroMQ Sockets. It depends on IntoInnerSocket 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 IntoInnerSocket, 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.