Structsยง

Eventbus
The core struct to communicate with vert.x eventbus. Can be created by calling Eventbus::connect.
EventbusReadStream
Responsible for reading messages from the server through vert.x protocol. It will decode and dispatch messages to related future/stream. Should be spawned into background. Can be created by calling Eventbus::connect.
EventbusWriteFuture
Responsible for writing messages to the server through vert.x protocol. Should be spawned into background. Can be created by calling Eventbus::connect.
ResponseFut
A future of response messages from a send_reply operation. Can be created by Eventbus.send_reply.
ResponseStream
A stream of response messages from a subscribe/register operation. Can be created by Eventbus.register.
UnboundedReceiverWithError