Module tokio_zmq::async_types

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

future	This module contains definitions for MultipartRequest and MultipartResponse, the two types that implement futures::Future.
sink	This module defines the MultipartSink type. A wrapper around Sockets that implements futures::Sink.
sink_stream	This module defines the MultipartSinkStream type. A wrapper around Sockets that implements futures::Sink and futures::Stream.
stream

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

Enums

MsgPlace

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.

Type Definitions

EventedFile