Crate fluvio_socket[][src]

Structs

AsyncResponse

Implement async socket where response are send back async manner they are queued using channel

ExclusiveFlvSink

Multi-thread aware Sink. Only allow sending request one a time.

FluvioSink
FluvioSocket

Socket abstract that can send and receive fluvio objects

FluvioStream

inner flv stream which is generic over stream

MultiplexerSocket

Socket that can multiplex connections

Enums

FlvSocketError

Traits

Connection

Functions

send_and_receive

send request and return response from calling server at socket addr

Type Definitions

BoxConnection
SharedMultiplexerSocket