stream

Module: broker::stream

Contents

Enums

• BrokerStream - A connected broker socket, abstracting over the TCP and Unix transports.

---

firma_secret_provider::broker::stream::BrokerStream

Enum

A connected broker socket, abstracting over the TCP and Unix transports.

Shared by the shim-side [super::client::BrokerClient] (outbound connections) and the broker-side [super::server::BrokerListener] (accepted connections). Peer credentials are validated on the concrete socket before it is erased here.

Variants:

• Tcp{ stream: tokio::net::TcpStream }
• Unix{ stream: tokio::net::UnixStream }

Trait Implementations:

• AsyncRead
  • fn poll_read(self: Pin<& mut Self>, cx: & mut Context, buf: & mut ReadBuf) -> Poll<io::Result<()>>
• AsyncWrite
  • fn is_write_vectored(self: &Self) -> bool
  • fn poll_flush(self: Pin<& mut Self>, cx: & mut Context) -> Poll<io::Result<()>>
  • fn poll_shutdown(self: Pin<& mut Self>, cx: & mut Context) -> Poll<io::Result<()>>
  • fn poll_write(self: Pin<& mut Self>, cx: & mut Context, buf: &[u8]) -> Poll<io::Result<usize>>
  • fn poll_write_vectored(self: Pin<& mut Self>, cx: & mut Context, bufs: &[io::IoSlice]) -> Poll<io::Result<usize>>