Struct SpinSockets 

pub struct SpinSockets<T>(/* private fields */);

HasData accessor for SpinSocketsView, used in place of WasiSockets when registering TCP socket bindings so that start_connect and drop can participate in socket quota tracking.

Trait Implementations

impl<T: 'static> HasData for SpinSockets<T>

type Data<'a> = SpinSocketsView<'a, T>

The data associated with this trait implementation, chiefly used as a generic associated type to allow plumbing the 'a lifetime into the definition here.

impl<T: Send + 'static> HostTcpSocketWithStore<T> for SpinSockets<T>

async fn connect( store: &Accessor<T, Self>, socket: Resource<TcpSocket>, remote_address: p3_IpSocketAddress, ) -> P3SocketResult<()>

Connect to a remote endpoint.

async fn listen( store: Access<'_, T, Self>, socket: Resource<TcpSocket>, ) -> P3SocketResult<StreamReader<Resource<TcpSocket>>>

Start listening and return a stream of new inbound connections.

fn send( store: Access<'_, T, Self>, socket: Resource<TcpSocket>, data: StreamReader<u8>, ) -> Result<FutureReader<Result<(), p3_ErrorCode>>>

Transmit data to peer.

fn receive( store: Access<'_, T, Self>, socket: Resource<TcpSocket>, ) -> Result<(StreamReader<u8>, FutureReader<Result<(), p3_ErrorCode>>)>

Read data from peer.

impl<T: 'static> HostUdpSocketWithStore<T> for SpinSockets<T>

async fn send( store: &Accessor<T, Self>, socket: Resource<UdpSocket>, data: Vec<u8>, remote_address: Option<p3_IpSocketAddress>, ) -> P3SocketResult<()>

Send a message on the socket to a particular peer.

async fn receive( store: &Accessor<T, Self>, socket: Resource<UdpSocket>, ) -> P3SocketResult<(Vec<u8>, p3_IpSocketAddress)>

Receive a message on the socket.