Struct Connection

pub struct Connection<Req, ReqMulti> { /* private fields */ }

A connection to a single stream transport.

Implementations

impl<Req, ReqMulti> Connection<Req, ReqMulti>

pub fn new<Stream>(stream: Stream) -> (Self, Transport<Stream, Req, ReqMulti>)

Creates a new stream transport with default configuration.

Returns a connection and a future that drives the transport using the provided stream. This future needs to be run while any queries are active. This is most easly achieved by spawning it into a runtime. It terminates when the last connection is dropped.

pub fn with_config<Stream>( stream: Stream, config: Config, ) -> (Self, Transport<Stream, Req, ReqMulti>)

Creates a new stream transport with the given configuration.

Returns a connection and a future that drives the transport using the provided stream. This future needs to be run while any queries are active. This is most easly achieved by spawning it into a runtime. It terminates when the last connection is dropped.

impl<Req, ReqMulti> Connection<Req, ReqMulti>

where Req: ComposeRequest + 'static, ReqMulti: ComposeRequestMulti + 'static,

pub fn get_request(&self, request_msg: Req) -> Request

Returns a request handler for a request.

Trait Implementations

impl<Req, ReqMulti> Clone for Connection<Req, ReqMulti>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<Req: Debug, ReqMulti: Debug> Debug for Connection<Req, ReqMulti>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<Req, ReqMulti> SendRequest<Req> for Connection<Req, ReqMulti>

where Req: ComposeRequest + 'static, ReqMulti: ComposeRequestMulti + Debug + Send + Sync + 'static,

fn send_request(&self, request_msg: Req) -> Box<dyn GetResponse + Send + Sync>

Request function that takes a ComposeRequest type.

impl<Req, ReqMulti> SendRequestMulti<ReqMulti> for Connection<Req, ReqMulti>

where Req: ComposeRequest + Debug + Send + Sync + 'static, ReqMulti: ComposeRequestMulti + 'static,

fn send_request( &self, request_msg: ReqMulti, ) -> Box<dyn GetResponseMulti + Send + Sync>

Request function that takes a ComposeRequestMulti type.