Struct Driver 

pub struct Driver<H: Handler<DriverReplySink>> { /* private fields */ }

Per-connection driver. Tracks in-flight request attempts, dispatches incoming requests to a Handler, and manages channel state / flow control.

Implementations

impl<H: Handler<DriverReplySink>> Driver<H>

pub fn new(handle: ConnectionHandle, handler: H) -> Self

pub fn with_operation_store( handle: ConnectionHandle, handler: H, operation_store: Arc<dyn OperationStore>, ) -> Self

pub fn caller(&self) -> DriverCaller

pub async fn run(&mut self)

Main loop: receive messages from the session and dispatch them. Handler calls run as spawned tasks — we don’t block the driver loop waiting for a handler to finish.