[][src]Crate async_zmq_types

Provide useful types and traits for working with ZMQ Asynchronously.

Structs

ControlledStream

ControlledStreams are used when you want a stream of multiparts, but you want to be able to turn it off.

EndingStream

A stream that ends when the EndHandler's should_stop method returns True

Multipart

This type is used for receiving and sending messages in Multipart groups. An application could make using this easier by implementing traits as follows:

PairConfig

The final builder step for the Pair socket type.

SockConfig

The final builder step for some socket types

SocketBuilder

The root struct for a Socket builder

SubConfig

The final builder step for the Sub socket type.

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

InnerSocket

Define all actions possible on a socket

IntoInnerSocket

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

IntoSocket
Pair
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.

Sub
UnPair
UnSub
WithEndHandler

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