Struct ServerConn 

pub struct ServerConn { /* private fields */ }

Outbound server-side connection driver.

The struct owns the transport-bound Conn plus the receiving half of the request channel that feeds it.

Implementations

impl ServerConn

pub fn new( conn: Conn, requests: Receiver<OutboundRequest>, data_store: DataStore, ) -> Self

Wrap an outbound Conn with the given request-channel receiver and data-store flavor.

Examples

use dynomite::conf::DataStore;
use dynomite::io::reactor::{ConnRole, TcpTransport};
use dynomite::net::{Conn, ServerConn};
use tokio::sync::mpsc;
let s = tokio::net::TcpStream::connect("127.0.0.1:6379").await.unwrap();
let conn = Conn::new(Box::new(TcpTransport::new(s, ConnRole::Server)), ConnRole::Server);
let (_tx, rx) = mpsc::channel(8);
let _ = ServerConn::new(conn, rx, DataStore::Redis);

pub fn conn(&self) -> &Conn

Borrow the underlying connection.

pub fn conn_mut(&mut self) -> &mut Conn

Mutably borrow the underlying connection.

pub async fn run(self) -> Result<(), NetError>

Drive the server FSM until either the request channel is closed or the transport hits EOF / error.

Errors

Surfaces transport- and protocol-level errors.