Expand description
Provide useful types and traits for working with ZMQ Asynchronously.
Structs§
- Controlled
Stream ControlledStreams are used when you want a stream of multiparts, but you want to be able to turn it off.- Ending
Stream - A stream that ends when the
EndHandler’sshould_stopmethod 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:
- Pair
Config - The final builder step for the Pair socket type.
- Sock
Config - The final builder step for some socket types
- Socket
Builder - The root struct for a Socket builder
- SubConfig
- The final builder step for the Sub socket type.
Traits§
- Build
- Control
Handler - The
ControlHandlertrait 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
EndHandlertrait 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
- Inner
Socket - Define all actions possible on a socket
- Into
Inner Socket - The
IntoInnerSockettrait is implemented for all wrapper types. This makes implementing other traits a matter of saying a given type implements them. - Into
Socket - Pair
- Sink
Socket - This trait provides the basic Sink support for ZeroMQ Sockets. It depends on
IntoInnerSocketand provides thesendandsinkmethods. - Sink
Stream Socket - This trait is provided for sockets that implement both Sync and Stream
- Stream
Socket - This trait provides the basic Stream support for ZeroMQ Sockets. It depends on
IntoInnerSocket, but provides implementations forsinkandrecv. - Sub
- UnPair
- UnSub
- With
EndHandler - This trait is provided to allow for ending a stream based on a Multipart message it receives.