Enum rxqlite_client::NetStream

pub enum NetStream {
    Tls(FramedWrite<WriteHalf<TlsStream<TcpStream>>, LengthDelimitedCodec>, FramedRead<ReadHalf<TlsStream<TcpStream>>, LengthDelimitedCodec>),
    Tcp(FramedWrite<WriteHalf<TcpStream>, LengthDelimitedCodec>, FramedRead<ReadHalf<TcpStream>, LengthDelimitedCodec>),
}

Variants

Tls(FramedWrite<WriteHalf<TlsStream<TcpStream>>, LengthDelimitedCodec>, FramedRead<ReadHalf<TlsStream<TcpStream>>, LengthDelimitedCodec>)

Tcp(FramedWrite<WriteHalf<TcpStream>, LengthDelimitedCodec>, FramedRead<ReadHalf<TcpStream>, LengthDelimitedCodec>)

Implementations

impl NetStream

pub async fn write( &mut self, notification_request: NotificationRequest ) -> Result<()>

pub async fn read(&mut self) -> Result<NotificationEvent>

pub async fn read_timeout( &mut self, timeout_duration: Duration ) -> Result<Option<NotificationEvent>>

Trait Implementations

impl From<TcpStream> for NetStream

fn from(stream: TcpStream) -> Self

Converts to this type from the input type.

impl From<TlsStream<TcpStream>> for NetStream

fn from(stream: TlsStream<TcpStream>) -> Self

Converts to this type from the input type.