Struct locutus_core::WebSocketProxy

pub struct WebSocketProxy { /* private fields */ }

Implementations

impl WebSocketProxy

pub fn as_upgrade<T>(
    socket: T,
    server_config: BoxedFilter<(impl Reply + 'static,)>
) -> impl Future<Output = Result<Self, Box<dyn Error + Send + Sync + 'static>>>where
    T: Into<SocketAddr>,

Starts this as an upgrade to an existing HTTP connection at the /ws-api URL

pub fn start_server<T>(
    socket: T
) -> impl Future<Output = Result<Self, Box<dyn Error + Send + Sync + 'static>>>where
    T: Into<SocketAddr>,

Starts the websocket connection at the default /ws-api URL

Trait Implementations

impl ClientEventsProxy for WebSocketProxy

fn recv(&mut self) -> BoxFuture<'_, Result<OpenRequest<'static>, ClientError>>

Cancellation Safety

fn send(
    &mut self,
    client: ClientId,
    response: Result<HostResponse, ClientError>
) -> BoxFuture<'_, Result<(), ClientError>>

Sends a response from the host to the client application.