Struct StreamSocketProxy 

pub struct StreamSocketProxy { /* private fields */ }

Implementations

impl StreamSocketProxy

pub fn new(channel: AsyncChannel) -> Self

Create a new Proxy for fuchsia.vsock/StreamSocket.

pub fn take_event_stream(&self) -> StreamSocketEventStream

Get a Stream of events from the remote end of the protocol.

Panics

Panics if the event stream was already taken.

pub fn close( &self, ) -> QueryResponseFut<CloseableCloseResult, DefaultFuchsiaResourceDialect>

Terminates the connection.

After calling Close, the client must not send any other requests.

Servers, after sending the status response, should close the connection regardless of status and without sending an epitaph.

Closing the client end of the channel should be semantically equivalent to calling Close without knowing when the close has completed or its status.

pub fn bind( &self, addr: &VsockAddress, ) -> QueryResponseFut<StreamSocketBindResult, DefaultFuchsiaResourceDialect>

Bind this socket to a specific address.

pub fn connect( &self, remote_address: &VsockAddress, ) -> QueryResponseFut<StreamSocketConnectResult, DefaultFuchsiaResourceDialect>

Initiate a connection to |remote_address|. When the connection attempt completes the signal SIGNAL_STREAM_CONNECTED will be asserted on the data plane zx.Handle:SOCKET.

pub fn listen( &self, backlog: i32, ) -> QueryResponseFut<StreamSocketListenResult, DefaultFuchsiaResourceDialect>

Places this socket into listening mode with a specified backlog. When a new connection is available the signal SIGNAL_STREAM_INCOMING will be asserted on the data plane zx.Handle:SOCKET.

pub fn accept( &self, want_addr: bool, ) -> QueryResponseFut<StreamSocketAcceptResult, DefaultFuchsiaResourceDialect>

Accepts a connection from this socket’s listen backlog and binds it to |socket| with data plane |data|. If |want_addr| is true, returns the address of the accepted socket. When this call returns, if SIGNAL_STREAM_INCOMING is asserted another incoming connection is available.

pub fn get_sock_name( &self, ) -> QueryResponseFut<StreamSocketGetSockNameResult, DefaultFuchsiaResourceDialect>

Retrieves the local socket address.

pub fn get_peer_name( &self, ) -> QueryResponseFut<StreamSocketGetPeerNameResult, DefaultFuchsiaResourceDialect>

Retrieves the remote socket address.

pub fn get_error( &self, ) -> QueryResponseFut<StreamSocketGetErrorResult, DefaultFuchsiaResourceDialect>

Get SOL_SOCKET -> SO_ERROR

Trait Implementations

impl Clone for StreamSocketProxy

fn clone(&self) -> StreamSocketProxy

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for StreamSocketProxy

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Proxy for StreamSocketProxy

type Protocol = StreamSocketMarker

The protocol which this Proxy controls.

fn from_channel(inner: AsyncChannel) -> Self

Create a proxy over the given channel.

fn into_channel(self) -> Result<AsyncChannel, Self>

Attempt to convert the proxy back into a channel.

fn as_channel(&self) -> &AsyncChannel

Get a reference to the proxy’s underlying channel.

fn into_client_end(self) -> Result<ClientEnd<Self::Protocol>, Self>

Attempt to convert the proxy back into a client end.

fn is_closed(&self) -> bool

Returns true if the proxy has received the PEER_CLOSED signal.

fn on_closed(&self) -> OnSignals<'_, Unowned<'_, Handle>>

Returns a future that completes when the proxy receives the PEER_CLOSED signal.

impl StreamSocketProxyInterface for StreamSocketProxy

type CloseResponseFut = QueryResponseFut<Result<(), i32>>

type BindResponseFut = QueryResponseFut<Result<(), Error>>

type ConnectResponseFut = QueryResponseFut<Result<(), Error>>

type ListenResponseFut = QueryResponseFut<Result<(), Error>>

type AcceptResponseFut = QueryResponseFut<Result<StreamSocketAcceptResponse, Error>>

type GetSockNameResponseFut = QueryResponseFut<Result<VsockAddress, Error>>

type GetPeerNameResponseFut = QueryResponseFut<Result<VsockAddress, Error>>

type GetErrorResponseFut = QueryResponseFut<Result<(), Error>>

fn close(&self) -> Self::CloseResponseFut

fn bind(&self, addr: &VsockAddress) -> Self::BindResponseFut

fn connect(&self, remote_address: &VsockAddress) -> Self::ConnectResponseFut

fn listen(&self, backlog: i32) -> Self::ListenResponseFut

fn accept(&self, want_addr: bool) -> Self::AcceptResponseFut

fn get_sock_name(&self) -> Self::GetSockNameResponseFut

fn get_peer_name(&self) -> Self::GetPeerNameResponseFut

fn get_error(&self) -> Self::GetErrorResponseFut