Struct Connection 

pub struct Connection { /* private fields */ }

An established Unix domain socket connection to a walrus-gateway.

Not Clone — one connection per session. Use super::WalrusClient::connect to create a connection.

Implementations

impl Connection

pub async fn connect(socket_path: &Path) -> Result<Self>

Connect to a gateway at the given socket path.

pub async fn send(&mut self, msg: ClientMessage) -> Result<ServerMessage>

Send a message and wait for a single response.

pub fn stream( &mut self, msg: ClientMessage, ) -> impl Stream<Item = Result<ServerMessage>> + '_

Send a message and return a stream of server responses.

The stream yields messages until StreamEnd is received or the connection closes. The StreamEnd message itself is not yielded.

pub fn download_stream( &mut self, msg: ClientMessage, ) -> impl Stream<Item = Result<ServerMessage>> + '_

Send a download request and return a stream of progress messages.

The stream yields messages until DownloadEnd or Error is received.

pub fn close(self)

Close the connection by dropping both halves.