Crate fluvio_socket[−][src]
Structs
AsyncResponse | Implement async socket where response are send back async manner they are queued using channel |
InnerExclusiveFlvSink | Multi-thread aware Sink. Only allow sending request one a time. |
InnerFlvSink | |
InnerFlvSocket | Socket abstract that can send and receive fluvio objects |
InnerFlvStream | inner flv stream which is generic over stream |
MultiplexerSocket | Socket that can multiplex connections |
SinkPool | Pool of sinks. This is lightweight version of SocketPool where you only need to keep track of sink no attemp to keep id indexes |
SocketPool | pooling of sockets |
Enums
FlvSocketError |
Functions
send_and_receive | send request and return response from calling server at socket addr |
Type Definitions
DefaultMultiplexerSocket | |
ExclusiveFlvSink | |
FlvSink | |
FlvSocket | |
FlvStream | |
SharedMultiplexerSocket | |
SharedSinkPool |