Module tokio_zmq::async_types
source · Expand description
This module contains the code that makes Tokio ZMQ Asynchronous. There’s the future
module,
which defines Request and Response futures for ZeroMQ Sockets, the stream
module, which
defines receiving data from a socket as an asychronous stream, and the sink
module, which
defines sending data to a socket as an asychronous sink.
Re-exports
pub use self::future::MultipartRequest;
pub use self::future::MultipartResponse;
pub use self::sink::MultipartSink;
pub use self::sink_stream::MultipartSinkStream;
pub use self::stream::MultipartStream;
pub use self::stream::TimeoutStream;
Modules
This module contains definitions for
MultipartRequest
and MultipartResponse
, the two types that
implement futures::Future
.This module defines the
MultipartSink
type. A wrapper around Sockets that implements
futures::Sink
.This module defines the
MultipartSinkStream
type. A wrapper around Sockets that implements
futures::Sink
and futures::Stream
.Structs
ControlledStream
s are used when you want a stream of multiparts, but you want to be able to
turn it off.A stream that ends when the
EndHandler
’s should_stop
method returns TrueEnums
This type is used to determine what flags should be used when sending messages. If a message is
the last in it’s
Multipart
, it should not have the SNDMORE flag set.