Struct ServerWebSocket
pub struct ServerWebSocket { /* private fields */ }Expand description
Server WebSocket, used as input-output stream.
Utility type created via WebSocketAcceptorService.
[AcceptedSubProtocol] can be found in the [Context], if any.
Implementations§
§impl ServerWebSocket
impl ServerWebSocket
pub fn request(&self) -> &Parts
pub fn request(&self) -> &Parts
View the original request data, from which this server web socket was created.
pub fn into_inner(self) -> AsyncWebSocket
pub fn into_inner(self) -> AsyncWebSocket
Consume self as an `AsyncWebSocket.
pub fn into_parts(self) -> (AsyncWebSocket, Parts)
pub fn into_parts(self) -> (AsyncWebSocket, Parts)
Consume self into its parts.
Methods from Deref<Target = AsyncWebSocket>§
pub fn get_config(&self) -> &WebSocketConfig
pub fn get_config(&self) -> &WebSocketConfig
Returns a reference to the configuration of the tungstenite stream.
pub async fn close(
&mut self,
msg: Option<CloseFrame>,
) -> Result<(), ProtocolError>
pub async fn close( &mut self, msg: Option<CloseFrame>, ) -> Result<(), ProtocolError>
Close the underlying web socket
pub fn send_message(
&mut self,
msg: Message,
) -> impl Future<Output = Result<(), ProtocolError>> + Send
pub fn send_message( &mut self, msg: Message, ) -> impl Future<Output = Result<(), ProtocolError>> + Send
Writes and immediately flushes a message.
pub async fn recv_message(&mut self) -> Result<Message, ProtocolError>
Trait Implementations§
§impl Debug for ServerWebSocket
impl Debug for ServerWebSocket
§impl Deref for ServerWebSocket
impl Deref for ServerWebSocket
§type Target = AsyncWebSocket
type Target = AsyncWebSocket
The resulting type after dereferencing.
§fn deref(&self) -> &<ServerWebSocket as Deref>::Target
fn deref(&self) -> &<ServerWebSocket as Deref>::Target
Dereferences the value.
§impl DerefMut for ServerWebSocket
impl DerefMut for ServerWebSocket
§fn deref_mut(&mut self) -> &mut <ServerWebSocket as Deref>::Target
fn deref_mut(&mut self) -> &mut <ServerWebSocket as Deref>::Target
Mutably dereferences the value.
§impl Service<ServerWebSocket> for WebSocketEchoService
impl Service<ServerWebSocket> for WebSocketEchoService
§type Error = OpaqueError
type Error = OpaqueError
The type of error returned by the service.
§async fn serve(
&self,
socket: ServerWebSocket,
) -> Result<<WebSocketEchoService as Service<ServerWebSocket>>::Response, <WebSocketEchoService as Service<ServerWebSocket>>::Error>
async fn serve( &self, socket: ServerWebSocket, ) -> Result<<WebSocketEchoService as Service<ServerWebSocket>>::Response, <WebSocketEchoService as Service<ServerWebSocket>>::Error>
Serve a response or error for the given request,
using the given context.
§fn boxed(self) -> BoxService<Request, Self::Response, Self::Error>
fn boxed(self) -> BoxService<Request, Self::Response, Self::Error>
Box this service to allow for dynamic dispatch.
Auto Trait Implementations§
impl !Freeze for ServerWebSocket
impl !RefUnwindSafe for ServerWebSocket
impl Send for ServerWebSocket
impl !Sync for ServerWebSocket
impl Unpin for ServerWebSocket
impl !UnwindSafe for ServerWebSocket
Blanket Implementations§
§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
§fn with_current_context(self) -> WithContext<Self> ⓘ
fn with_current_context(self) -> WithContext<Self> ⓘ
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more§impl<T> Pointable for T
impl<T> Pointable for T
§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
§fn and<P, B, E>(self, other: P) -> And<T, P>
fn and<P, B, E>(self, other: P) -> And<T, P>
Create a new
Policy that returns Action::Follow only if self and other return
Action::Follow. Read more