[−][src]Enum ws_stream_wasm::WsEvent
Events related to the WebSocket. You can filter like:
use { ws_stream_wasm :: * , pharos :: * , wasm_bindgen :: UnwrapThrowExt , wasm_bindgen_futures :: futures_0_3::spawn_local , futures :: stream::StreamExt , }; let program = async { let (mut ws, _wsio) = WsMeta::connect( "127.0.0.1:3012", None ).await .expect_throw( "assume the connection succeeds" ); // The Filter type comes from the pharos crate. // let mut evts = ws.observe( Filter::Pointer( WsEvent::is_closed ).into() ); ws.close().await; // Note we will only get the closed event here, the WsEvent::Closing has been filtered out. // assert!( evts.next().await.unwrap_throw().is_closed () ); }; spawn_local( program );
Variants
The connection is now Open and ready for use.
An error happened on the connection. For more information about when this event occurs, see the HTML Living Standard. Since the browser is not allowed to convey any information to the client code as to why an error happened (for security reasons), as described in the HTML specification, there usually is no extra information available. That's why this event has no data attached to it.
The connection has started closing, but is not closed yet. You shouldn't try to send messages over it anymore. Trying to do so will result in an error.
Closed(CloseEvent)
The connection was closed. The enclosed CloseEvent
has some extra information.
WsErr(WsErr)
An error happened, not on the connection, but inside ws_stream_wasm. This currently happens when an incoming message can not be converted to Rust types, eg. a String message with invalid encoding.
Implementations
impl WsEvent
[src]
pub fn is_open(&self) -> bool
[src]
Predicate indicating whether this is a WsEvent::Open event. Can be used as a filter for the
event stream obtained with pharos::Observable::observe
on WsMeta
.
pub fn is_err(&self) -> bool
[src]
Predicate indicating whether this is a WsEvent::Error event. Can be used as a filter for the
event stream obtained with pharos::Observable::observe
on WsMeta
.
pub fn is_closing(&self) -> bool
[src]
Predicate indicating whether this is a WsEvent::Closing event. Can be used as a filter for the
event stream obtained with pharos::Observable::observe
on WsMeta
.
pub fn is_closed(&self) -> bool
[src]
Predicate indicating whether this is a WsEvent::Closed event. Can be used as a filter for the
event stream obtained with pharos::Observable::observe
on WsMeta
.
pub fn is_ws_err(&self) -> bool
[src]
Predicate indicating whether this is a WsEvent::WsErr event. Can be used as a filter for the
event stream obtained with pharos::Observable::observe
on WsMeta
.
Trait Implementations
impl Clone for WsEvent
[src]
impl Debug for WsEvent
[src]
impl Eq for WsEvent
[src]
impl Observable<WsEvent> for WsMeta
[src]
type Error = Error
The error type that is returned if observing is not possible. Read more
fn observe(
&mut self,
options: ObserveConfig<WsEvent>
) -> Result<Events<WsEvent>, Self::Error>
[src]
&mut self,
options: ObserveConfig<WsEvent>
) -> Result<Events<WsEvent>, Self::Error>
impl PartialEq<WsEvent> for WsEvent
[src]
impl StructuralEq for WsEvent
[src]
impl StructuralPartialEq for WsEvent
[src]
Auto Trait Implementations
impl RefUnwindSafe for WsEvent
impl Send for WsEvent
impl Sync for WsEvent
impl Unpin for WsEvent
impl UnwindSafe for WsEvent
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
fn to_owned(&self) -> T
[src]
fn clone_into(&self, target: &mut T)
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,