MCPcopy Create free account

hub / github.com/MercuryWorkshop/epoxy-tls / functions

Functions459 in github.com/MercuryWorkshop/epoxy-tls

⨍ Functions 459◇ Types & classes 140
↓ 91 callersMethodclone
(&self)
client/src/utils/js.rs:134
↓ 52 callersMethodlock
(&self, key: Option<usize>, cx: &mut Context<'_>)
wisp/src/locked_sink.rs:132
↓ 46 callersMethodget
caller must make sure they are the ones locking the sink
wisp/src/locked_sink.rs:125
↓ 45 callersFunctionlog
(str)
client/demo.js:28
↓ 38 callersMethodclose
( &mut self, code: CloseCode, reason: &str, )
server/src/stream.rs:312
↓ 26 callersMethodclone
(&self)
wisp/src/extensions/mod.rs:66
↓ 18 callersMethodunlock
(&self)
wisp/src/locked_sink.rs:147
↓ 12 callersMethodencode
(&self)
wisp/src/extensions/udp.rs:26
↓ 12 callersMethodremove
(&mut self, key: usize)
wisp/src/locked_sink.rs:72
↓ 12 callersMethodsend
Send a protocol extension packet with this stream's ID.
wisp/src/stream/handles.rs:56
↓ 12 callersMethodsplit
(self)
server/src/listener.rs:255
↓ 10 callersMethodinto_split
(self)
server/src/listener.rs:169
↓ 9 callersMethodsend
(&self, payload: EpoxyWebSocketInput)
client/src/websocket.rs:161
↓ 7 callersMethodclose
(&self, code: u16, reason: String)
client/src/websocket.rs:196
↓ 7 callersMethodget_id
(&self)
wisp/src/extensions/udp.rs:22
↓ 6 callersMethodencode_into
(&self, packet: &mut PayloadMut)
wisp/src/packet.rs:33
↓ 6 callersMethodfetch
( &self, url: EpoxyUrlInput, options: Object, )
client/src/lib.rs:580
↓ 5 callersMethodencode
(&self)
wisp/src/packet.rs:311
↓ 5 callersFunctionlock
(mutex: &Mutex<T>)
wisp/src/ws/split.rs:7
↓ 5 callersMethodread
(&mut self)
server/src/stream.rs:296
↓ 5 callersFunctiontest_mux
(url)
client/demo.js:69
↓ 5 callersMethodupdate
(&mut self, key: usize, cx: &mut Context<'_>)
wisp/src/locked_sink.rs:65
↓ 4 callersMethodaccept
(&mut self)
server/src/listener.rs:391
↓ 4 callersMethodclone
(&self)
wisp/src/locked_sink.rs:170
↓ 4 callersFunctionentries_of_object
(obj: &Object)
client/src/utils/js.rs:186
↓ 4 callersMethodget_close_handle
(&self)
wisp/src/stream/mod.rs:162
↓ 4 callersMethodget_reason
(&self)
wisp/src/mux/inner.rs:127
↓ 4 callersMethodinto_async_rw
(self)
wisp/src/stream/mod.rs:327
↓ 4 callersMethodlock_waiters
(&self)
wisp/src/locked_sink.rs:112
↓ 4 callersMethodnew_stream
Create a new stream, multiplexed through Wisp.
wisp/src/mux/client.rs:146
↓ 4 callersMethodnext_erroring
(&mut self)
wisp/src/ws/mod.rs:69
↓ 4 callersFunctionobject_truthy
(val: JsValue)
client/src/utils/js.rs:209
↓ 4 callersFunctionsplit
( s: S, )
wisp/src/ws/split.rs:11
↓ 4 callersFunctiontest_native
(url)
client/demo.js:76
↓ 4 callersMethodwake
(&mut self)
wisp/src/locked_sink.rs:44
↓ 4 callersMethodwith_required_extensions
Require protocol extensions by their ID. Will close the multiplexor connection if extensions are not supported.
wisp/src/mux/mod.rs:274
↓ 3 callersMethodclose
Close all streams. Also terminates the multiplexor future.
wisp/src/mux/mod.rs:229
↓ 3 callersMethoddecode
(packet: &mut Payload)
wisp/src/packet.rs:37
↓ 3 callersMethodget_asyncread
( &self, stream_type: StreamType, host: String, port: u16, )
client/src/stream_provider.rs:179
↓ 3 callersMethodget_extensions
Get a shared reference to the extensions that are supported by both sides.
wisp/src/mux/mod.rs:191
↓ 3 callersMethodget_future
(self: Pin<&mut Self>)
wisp/src/ws/unfold.rs:69
↓ 3 callersMethodget_tls_stream
( &self, host: String, port: u16, http: bool, )
client/src/stream_provider.rs:191
↓ 3 callersMethodget_unpin
(&self)
wisp/src/locked_sink.rs:118
↓ 3 callersMethodhandle_packet
(&mut self, packet: Packet<'static>)
wisp/src/mux/inner.rs:385
↓ 3 callersFunctionlisten_wisp
()
server/src/main.rs:284
↓ 3 callersMethodtake_state
(self: Pin<&mut Self>)
wisp/src/ws/unfold.rs:59
↓ 3 callersFunctionvalidate_continue_packet
(packet: &Packet)
wisp/src/mux/mod.rs:84
↓ 2 callersMethod__downcast
(self: Box<Self>)
wisp/src/extensions/mod.rs:150
↓ 2 callersMethod__downcast_mut
(&mut self)
wisp/src/extensions/mod.rs:169
↓ 2 callersMethod__downcast_ref
(&self)
wisp/src/extensions/mod.rs:161
↓ 2 callersMethod__internal_type_id
Do not override.
wisp/src/extensions/mod.rs:139
↓ 2 callersMethodadd
(&mut self, cx: &mut Context<'_>)
wisp/src/locked_sink.rs:61
↓ 2 callersMethodadd_stream
(&mut self, id: u32, ty: StreamType)
wisp/src/mux/inner.rs:362
↓ 2 callersFunctionallowed_set
(stream_type: StreamType)
server/src/stream.rs:28
↓ 2 callersFunctionasync_init
()
server/src/main.rs:152
↓ 2 callersMethodclose_internal
(&self, reason: Option<CloseReason>)
wisp/src/mux/mod.rs:219
↓ 2 callersFunctionconvert_body
(val: JsValue)
client/src/utils/js.rs:93
↓ 2 callersMethodcreate_client
( &self, mut locked: MutexGuard<'_, Option<ClientMux<ProviderWispTransportWrite>>>, )
client/src/stream_provider.rs:118
↓ 2 callersFunctioncreate_iostream
( stream: Pin<Box<dyn Stream<Item = Result<Bytes, EpoxyError>>>>, sink: Pin<Box<dyn Sink<Bytes, Error = Epox
client/src/io_stream.rs:15
↓ 2 callersFunctiondefault_motd
()
server/src/config.rs:151
↓ 2 callersMethodflow_dec
(&self)
wisp/src/mux/inner.rs:105
↓ 2 callersFunctiongenerate_stats
()
server/src/stats.rs:58
↓ 2 callersMethodget_close_reason
(&self)
wisp/src/stream/mod.rs:67
↓ 2 callersMethodget_handle
(&mut self)
wisp/src/locked_sink.rs:254
↓ 2 callersFunctionget_header
(headers: &HeaderMap, header: &str)
server/src/route.rs:89
↓ 2 callersMethodget_stream
( &self, stream_type: StreamType, host: String, port: u16, )
client/src/stream_provider.rs:160
↓ 2 callersFunctionget_supported_extensions
( extensions: Vec<AnyProtocolExtension>, builders: &mut [AnyProtocolExtensionBuilder], )
wisp/src/mux/mod.rs:96
↓ 2 callersMethodget_type
(&self)
wisp/src/packet.rs:343
↓ 2 callersFunctionhandle_handshake
( read: &mut R, write: &mut LockedWebSocketWrite<W>, extensions: &mut [AnyProtocolExtension], )
wisp/src/mux/mod.rs:46
↓ 2 callersFunctionhandle_stream
( connect: ConnectPacket, muxstream: MuxStream<WispStreamWrite>, id: String, event: Arc<Event>, #[cfg(fea
server/src/handle/wisp/mod.rs:229
↓ 2 callersMethodhandshake
( &mut self, rx: &mut R, tx: &mut LockedWebSocketWrite<W>, v2: Option<WispV2Handshake>, )
wisp/src/mux/server.rs:73
↓ 2 callersMethodhas_wispnet
(&self)
server/src/config.rs:383
↓ 2 callersFunctionheader_contains_value
Check if there is a header of the given name containing the wanted value.
server/src/upgrade.rs:16
↓ 2 callersFunctioninstantiateEpoxy
()
client-showcase/src/epoxy.ts:19
↓ 2 callersMethodinto_parts
(self)
wisp/src/mux/mod.rs:38
↓ 2 callersFunctioniostream_from_asyncrw
(asyncrw: ProviderAsyncRW, buffer_size: usize)
client/src/io_stream.rs:42
↓ 2 callersFunctionis_global
(addr: IpAddr)
server/src/stream.rs:108
↓ 2 callersFunctionlisten_stats
(bind_addr: BindAddr)
server/src/main.rs:263
↓ 2 callersFunctionlisten_stats_cli
()
server/src/main.rs:252
↓ 2 callersFunctionmatch_addr
(str: &str, allowed: &RegexSet, blocked: &RegexSet)
server/src/stream.rs:24
↓ 2 callersFunctionnon_ws_resp
()
server/src/route.rs:66
↓ 2 callersMethodother
(self)
wisp/src/unfair_select.rs:25
↓ 2 callersMethodpoll_next
( self: Pin<&mut Self>, cx: &mut std::task::Context<'_>, )
wisp/src/unfair_select.rs:72
↓ 2 callersFunctionpoll_side
( select: &mut UnfairSelectProj<'_, St1, St2>, side: PollNext, cx: &mut Context<'_>, )
wisp/src/unfair_select.rs:88
↓ 2 callersMethodregister
(&mut self, cx: &mut Context<'_>)
wisp/src/locked_sink.rs:37
↓ 2 callersFunctionroute_wispnet
(server: u32, packet: ConnectPacket)
server/src/handle/wisp/wispnet.rs:145
↓ 2 callersFunctionsend_info_packet
( write: &mut LockedWebSocketWrite<W>, builders: &mut [AnyProtocolExtensionBuilder], role: Role, )
wisp/src/mux/mod.rs:61
↓ 2 callersMethodsend_req_inner
( &self, req: http::Request<StreamingBody>, should_redirect: bool, )
client/src/lib.rs:525
↓ 2 callersFunctionsend_stats
()
server/src/route.rs:72
↓ 2 callersMethodsize_hint
(&self)
wisp/src/packet.rs:29
↓ 2 callersMethodsplit_fast
(self)
wisp/src/ws/mod.rs:79
↓ 2 callersMethodstart_send
(mut self: Pin<&mut Self>, item: Payload)
wisp/src/stream/mod.rs:237
↓ 2 callersFunctiontoHex
(arr: ArrayBuffer)
client-showcase/src/loggingws.ts:22
↓ 2 callersFunctiontoText
(arr: ArrayBuffer)
client-showcase/src/loggingws.ts:29
↓ 2 callersMethodwith_no_required_extensions
Require no protocol extensions.
wisp/src/mux/mod.rs:268
↓ 2 callersMethodwrite
(chunk)
client-showcase/src/loggingws.ts:91
↓ 2 callersMethodwrite
(&mut self, data: impl Into<Payload>)
server/src/stream.rs:308
↓ 1 callersMethodabort
()
client-showcase/src/loggingws.ts:96
↓ 1 callersMethodallowed_hosts
(&self)
server/src/config.rs:490
↓ 1 callersMethodallowed_ports
(&self)
server/src/config.rs:480
next →1–100 of 459, ranked by callers