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 |