1 viewer
rust 1,849,384 · typescript 232,426 · javascript 131,078 · python 19,227 · 6,366 files · digest 815dcbacab85 · built in 1.4 s · crystals off
crates/cre8-app-emulation/src/streaming.rs
Items
const SUBSCRIBER_CHANNEL_DEPTH const MAX_SUBSCRIBERS const SUBSCRIBER_RECV_TIMEOUT_MS const STREAM_SEND_TIMEOUT const STREAM_SEND_RETRY_INTERVAL const ATTACH_TIMEOUT struct StreamAdmission struct Subscriber struct QueuedFrame struct RemoteInput struct StreamRegistry static REGISTRY struct Subscription impl Drop for Subscription static LOCK
Functions
By call-graph weight (PageRank; 1.0 is the average function). 43 functions in all.
| function | kind | lines | cyclomatic | callers | callees | weight | crystal |
|---|---|---|---|---|---|---|---|
| rotatesrc/streaming.rs:174 | fn | 10 | 1 | 5 | 0 | 2.1 | |
| drain_deliverysrc/streaming.rs:184 | fn | 7 | 2 | 5 | 1 | 2.1 | |
| emu_frame_test_locksrc/streaming.rs:462 | fn | 4 | 1 | 9 | 0 | 2.1 | |
| register_subscribersrc/streaming.rs:118 | fn | 10 | 2 | 2 | 1 | 2 | |
| current_generationsrc/streaming.rs:107 | fn | 4 | 1 | 8 | 0 | 1.9 | |
| publish_lockedsrc/streaming.rs:143 | fn | 31 | 2 | 2 | 2 | 1.9 | |
| unregister_allsrc/streaming.rs:191 | fn | 10 | 1 | 13 | 2 | 1.4 | |
| serialsrc/streaming.rs:471 | fn | 3 | 1 | 13 | 1 | 1.4 | |
| send_message_with_deadlinesrc/streaming.rs:296 | fn | 26 | 6 | 2 | 1 | 1.4 | |
| subscribesrc/streaming.rs:129 | fn | 3 | 1 | 9 | 1 | 1.1 | |
| publish_framesrc/streaming.rs:140 | fn | 3 | 1 | 9 | 1 | 1.1 | |
| release_remote_inputsrc/streaming.rs:268 | fn | 8 | 3 | 1 | 0 | 1.1 | |
| configure_stream_socketsrc/streaming.rs:293 | fn | 3 | 1 | 3 | 0 | 1.1 | |
| handle_stream_connectionsrc/streaming.rs:393 | fn | 36 | 8 | 2 | 8 | 1 | |
| deliver_current_framesrc/streaming.rs:220 | fn | 7 | 2 | 6 | 0 | 0.9 | |
| send_jsonsrc/streaming.rs:322 | fn | 7 | 1 | 2 | 1 | 0.9 | |
| has_subscriberssrc/streaming.rs:201 | fn | 3 | 1 | 4 | 0 | 0.8 | |
| set_remote_inputsrc/streaming.rs:230 | fn | 38 | 14 | 2 | 0 | 0.8 | |
| subscribe_sessionsrc/streaming.rs:111 | fn | 7 | 3 | 3 | 1 | 0.7 | |
| send_next_stream_framesrc/streaming.rs:429 | fn | 23 | 6 | 2 | 3 | 0.7 | |
| invalidate_timelinesrc/streaming.rs:206 | fn | 4 | 1 | 3 | 2 | 0.7 | |
| begin_sessionsrc/streaming.rs:84 | fn | 10 | 1 | 3 | 2 | 0.6 | |
| await_admissionsrc/streaming.rs:329 | fn | 20 | 7 | 1 | 1 | 0.6 | |
| pump_client_framesrc/streaming.rs:349 | fn | 44 | 11 | 1 | 2 | 0.6 | |
| invalidate_sessionsrc/streaming.rs:210 | fn | 10 | 2 | 1 | 2 | 0.6 | |
| overlay_remote_inputsrc/streaming.rs:276 | fn | 16 | 5 | 1 | 0 | 0.6 | |
| end_sessionsrc/streaming.rs:94 | fn | 13 | 2 | 1 | 2 | 0.5 | |
| publish_frame_forsrc/streaming.rs:133 | fn | 6 | 2 | 1 | 1 | 0.5 | |
| Subscription::dropsrc/streaming.rs:76 | trait impl | 4 | 1 | 0 | 0 | 0.5 | |
| independent_subscribers_receive_without_displacementsrc/streaming.rs:476 | fn | 15 | 1 | 0 | 6 | 0.5 | |
| remote_input_is_fenced_and_does_not_overwrite_local_controlssrc/streaming.rs:493 | fn | 21 | 1 | 0 | 7 | 0.5 | |
| one_delivery_gate_does_not_block_another_subscribersrc/streaming.rs:516 | fn | 16 | 1 | 0 | 7 | 0.5 | |
| exact_session_capacity_and_stop_fencesrc/streaming.rs:534 | fn | 20 | 1 | 0 | 9 | 0.5 | |
| publish_with_no_subscriber_is_noopsrc/streaming.rs:557 | fn | 6 | 1 | 0 | 4 | 0.5 | |
| publish_delivers_to_subscribersrc/streaming.rs:566 | fn | 22 | 5 | 0 | 5 | 0.5 | |
| timeline_invalidation_discards_queued_and_already_dequeued_framessrc/streaming.rs:590 | fn | 21 | 1 | 0 | 8 | 0.5 | |
| timeline_invalidation_serializes_with_an_in_progress_deliverysrc/streaming.rs:613 | fn | 38 | 1 | 0 | 8 | 0.5 | |
| actual_session_restore_invalidates_stream_only_after_successsrc/streaming.rs:653 | fn | 27 | 1 | 0 | 11 | 0.5 | |
| stream_owner_configures_nonblocking_io_without_gateway_setupsrc/streaming.rs:682 | fn | 10 | 1 | 0 | 1 | 0.5 | |
| failed_socket_delivery_shuts_down_before_timeline_invalidationsrc/streaming.rs:694 | fn | 20 | 1 | 0 | 7 | 0.5 | |
| overflow_retains_latest_picturesrc/streaming.rs:717 | fn | 30 | 4 | 0 | 5 | 0.5 | |
| unregister_closes_subscribersrc/streaming.rs:751 | fn | 10 | 2 | 0 | 4 | 0.5 | |
| ws_refuses_legacy_input_before_attachmentsrc/streaming.rs:763 | fn | 17 | 1 | 0 | 4 | 0.5 |
Source not readable from this process.