Struct AsyncSession

pub struct AsyncSession<AS, ASTU>
where
    AS: AsRawFdOrSocket,
    Async<AS>: AsyncRead + AsyncWrite,
    ASTU: TlsClientUpgrader<Async<AS>> + Unpin,
    ASTU::Output: AsyncRead + AsyncWrite + Unpin,
{
    pub unsolicited_responses: Receiver<UnsolicitedResponse>,
    /* private fields */
}

Fields

unsolicited_responses: Receiver<UnsolicitedResponse>

Implementations

impl<AS, ASTU> AsyncSession<AS, ASTU>

where AS: AsRawFdOrSocket, Async<AS>: AsyncRead + AsyncWrite, ASTU: TlsClientUpgrader<Async<AS>> + UpgraderExtRefer<Async<AS>> + Unpin, ASTU::Output: AsyncRead + AsyncWrite + Unpin,

pub async fn select<S: AsRef<str>>( &mut self, mailbox_name: S, ) -> Result<Mailbox>

pub async fn fetch<S1, S2>( &mut self, sequence_set: S1, query: S2, ) -> ZeroCopyResult<Vec<Fetch>>

where S1: AsRef<str>, S2: AsRef<str>,

Methods from Deref<Target = AsyncConnection<AS, ASTU>>

pub async fn read_greeting(&mut self) -> Result<Vec<u8>>

pub async fn run_command_and_check_ok<S: AsRef<str>>( &mut self, command: S, ) -> Result<()>

pub async fn run_command_and_read_response<S: AsRef<str>>( &mut self, untagged_command: S, ) -> Result<Vec<u8>>

Trait Implementations

impl<AS, ASTU> Deref for AsyncSession<AS, ASTU>

where AS: AsRawFdOrSocket, Async<AS>: AsyncRead + AsyncWrite, ASTU: TlsClientUpgrader<Async<AS>> + Unpin, ASTU::Output: AsyncRead + AsyncWrite + Unpin,

type Target = AsyncConnection<AS, ASTU>

The resulting type after dereferencing.

fn deref(&self) -> &AsyncConnection<AS, ASTU>

Dereferences the value.

impl<AS, ASTU> DerefMut for AsyncSession<AS, ASTU>

where AS: AsRawFdOrSocket, Async<AS>: AsyncRead + AsyncWrite, ASTU: TlsClientUpgrader<Async<AS>> + Unpin, ASTU::Output: AsyncRead + AsyncWrite + Unpin,

fn deref_mut(&mut self) -> &mut AsyncConnection<AS, ASTU>

Mutably dereferences the value.