Struct Connection

pub struct Connection<S, T> { /* private fields */ }

A connection to a PostgreSQL database.

This is one half of what is returned when a new connection is established. It performs the actual IO with the server, and should generally be spawned off onto an executor to run in the background.

Connection implements Future, and only resolves when the connection is closed, either because a fatal error has occurred, or because its associated Client has dropped and all outstanding work has completed.

Implementations

impl<S, T> Connection<S, T>

where S: AsyncRead + AsyncWrite + Unpin, T: AsyncRead + AsyncWrite + Unpin,

pub fn parameter(&self, name: &str) -> Option<&str>

Returns the value of a runtime parameter for this connection.

pub fn poll_message( &mut self, cx: &mut Context<'_>, ) -> Poll<Option<Result<AsyncMessage, Error>>>

Polls for asynchronous messages from the server.

The server can send notices as well as notifications asynchronously to the client. Applications that wish to examine those messages should use this method to drive the connection rather than its Future implementation.

Return values of None or Some(Err(_)) are “terminal”; callers should not invoke this method again after receiving one of those values.

Trait Implementations

impl<S, T> Future for Connection<S, T>

where S: AsyncRead + AsyncWrite + Unpin, T: AsyncRead + AsyncWrite + Unpin,

type Output = Result<(), Error>

The type of value produced on completion.

fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Error>>

Attempts to resolve the future to a final value, registering the current task for wakeup if the value is not yet available.