1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82

#![cfg_attr( nightly, feature(doc_cfg) )]
#![cfg_attr( nightly, cfg_attr( nightly, doc = include_str!("../README.md") ))]
#![doc = ""] // empty doc line to handle missing doc warning when the feature is missing.

#![ doc    ( html_root_url = "https://docs.rs/ws_stream_wasm"            ) ]
#![ forbid ( unsafe_code                                                 ) ]
#![ allow  ( clippy::suspicious_else_formatting, clippy::needless_return ) ]


#![ warn
(
	missing_debug_implementations ,
	missing_docs                  ,
	nonstandard_style             ,
	rust_2018_idioms              ,
	trivial_casts                 ,
	trivial_numeric_casts         ,
	unused_extern_crates          ,
	unused_qualifications         ,
	single_use_lifetimes          ,
	unreachable_pub               ,
	variant_size_differences      ,
)]



mod error        ;
mod ws_event     ;
mod ws_message   ;
mod ws_meta      ;
mod ws_state     ;
mod ws_stream    ;
mod ws_stream_io ;

pub use
{
	error        :: { WsErr               } ,
	ws_event     :: { WsEvent, CloseEvent } ,
	ws_message   :: { WsMessage           } ,
	ws_meta      :: { WsMeta              } ,
	ws_state     :: { WsState             } ,
	ws_stream    :: { WsStream            } ,
	ws_stream_io :: { WsStreamIo          } ,
};



mod import
{
	pub(crate) use
	{
		futures              :: { prelude::{ Stream, Sink }, ready, StreamExt, FutureExt                         } ,
		std                  :: { io, collections::VecDeque, fmt, task::{ Context, Waker, Poll }, future::Future } ,
		std                  :: { rc::Rc, cell::{ RefCell }, pin::Pin, convert::{ TryFrom, TryInto }             } ,
		js_sys               :: { ArrayBuffer, Uint8Array                                                        } ,
		wasm_bindgen         :: { closure::Closure, JsCast, JsValue, UnwrapThrowExt                              } ,
		web_sys              :: { *, BinaryType, Blob, WebSocket, CloseEvent as JsCloseEvt, DomException         } ,
		js_sys               :: { Array                                                                          } ,
		pharos               :: { SharedPharos, PharErr, Observable, Observe, Filter, ObserveConfig,             } ,
		wasm_bindgen_futures :: { spawn_local                                                                    } ,
		async_io_stream      :: { IoStream                                                                       } ,
		thiserror            :: { Error                                                                          } ,
		send_wrapper         :: { SendWrapper                                                                    } ,
	};
}


use import::*;

/// Helper function to reduce code bloat
//
pub(crate) fn notify( pharos: SharedPharos<WsEvent>, evt: WsEvent )
{
	let notify = async move
	{
		pharos.notify( evt ).await

			.map_err( |e| unreachable!( "{:?}", e ) ).unwrap(); // only happens if we closed it.
	};

	spawn_local( notify );
}