Struct fluvio::sockets::VersionedSerialSocket
source · [−]pub struct VersionedSerialSocket { /* private fields */ }
Expand description
Connection that perform request/response
Implementations
pub fn new(
socket: SharedMultiplexerSocket,
config: Arc<ClientConfig>,
versions: Versions
) -> Self
pub async fn send_receive<R>(
&self,
request: R
) -> Result<R::Response, SocketError> where
R: Request + Send + Sync,
pub async fn send_receive<R>(
&self,
request: R
) -> Result<R::Response, SocketError> where
R: Request + Send + Sync,
send and wait for reply serially
Trait Implementations
Auto Trait Implementations
impl !RefUnwindSafe for VersionedSerialSocket
impl Sync for VersionedSerialSocket
impl Unpin for VersionedSerialSocket
impl !UnwindSafe for VersionedSerialSocket
Blanket Implementations
Mutably borrows from an owned value. Read more
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more