Struct tower_kafka::transport::MakeClient
source · pub struct MakeClient<C> { /* private fields */ }
Expand description
Helper for building new clients.
Implementations§
source§impl<C> MakeClient<C>where
C: MakeConnection + 'static,
impl<C> MakeClient<C>where
C: MakeConnection + 'static,
sourcepub fn with_connection(connection: C) -> Self
pub fn with_connection(connection: C) -> Self
Create a new MakeClient
with the provided connection.
sourcepub async fn into_client(
self
) -> Result<TransportClient<C::Connection>, C::Error>
pub async fn into_client(
self
) -> Result<TransportClient<C::Connection>, C::Error>
Wait for the connection and produce a new client instance when ready.