1pub(crate) mod error;
2pub(crate) mod generator;
3pub(crate) mod header;
4pub(crate) mod packet;
5#[cfg(feature = "server")]
6pub(crate) mod server;
7pub(crate) mod socket;
8pub(crate) mod transports;
9
10pub use error::Error;
11pub(crate) use error::Result;
12pub use generator::{Generator, StreamGenerator};
13pub use header::{HeaderMap, HeaderName, HeaderValue};
14pub use packet::{Packet, PacketType};
15#[cfg(feature = "server")]
16pub use server::{Server, ServerBuilder, ServerOption};
17pub use socket::{Event, Socket, SocketBuilder};
18
19pub type Sid = std::sync::Arc<String>;
20
21pub const ENGINE_IO_VERSION: i32 = 4;
22
23#[cfg(test)]
24pub(crate) mod test {
25 use reqwest::Url;
26
27 const RUST_SERVER_URL: &str = "http://localhost:4205";
28 const RUST_TIMEOUT_SERVER_URL: &str = "http://localhost:4206";
29
30 pub(crate) fn rust_engine_io_server() -> Url {
31 let url =
32 std::env::var("RUST_ENGINE_IO_SERVER").unwrap_or_else(|_| RUST_SERVER_URL.to_owned());
33 Url::parse(&url).unwrap()
34 }
35
36 pub(crate) fn rust_engine_io_timeout_server() -> Url {
37 let url = std::env::var("RUST_ENGINE_IO_TIMEOUT_SERVER")
38 .unwrap_or_else(|_| RUST_TIMEOUT_SERVER_URL.to_owned());
39 Url::parse(&url).unwrap()
40 }
41}