Skip to content
1 viewer

rust 1,860,549 · typescript 235,540 · javascript 132,956 · python 20,426 · 6,408 files · digest f04d4637f52b · built in 1.5 s · crystals off

register_subscriber

cre8_app_emulation::streaming::register_subscriber

fn · cre8-app-emulation · crates/cre8-app-emulation/src/streaming.rs:118

10lines
2cyclomatic
1max nesting
7statements
0? exits
1params
2callers
1callees
2 (p94)call-graph weight

Crystal

no crystal was derived for this function

Call neighbourhood

Callers left, callees right, two hops each way (2 direct callers, 1 direct callees; the heaviest shown). Dashed edges are method calls resolved by name alone.

name · 1 sitepath · 1 sitename · 2 sitesname · 2 sitesname · 6 sitesname · 1 sitename · 2 sitesname · 1 sitename · 2 sitesname · 1 sitename · 1 sitename · 1 sitepath · 1 sitehandle_stream_connectionapp-emulation · cc 8cre8_app_emulation::streaming::handle_stream_connectionretiring_old_owner_is_idemp…app-emulation · cc 1cre8_app_emulation::session::storage_tests::retiring_old_owner_is_idempotent_and_drop_preserves_successor_outputindependent_subscribers_rec…app-emulation · cc 1cre8_app_emulation::streaming::tests::independent_subscribers_receive_without_displacementone_delivery_gate_does_not_…app-emulation · cc 1cre8_app_emulation::streaming::tests::one_delivery_gate_does_not_block_another_subscriberexact_session_capacity_and_…app-emulation · cc 1cre8_app_emulation::streaming::tests::exact_session_capacity_and_stop_fencepublish_delivers_to_subscri…app-emulation · cc 5cre8_app_emulation::streaming::tests::publish_delivers_to_subscribertimeline_invalidation_disca…app-emulation · cc 1cre8_app_emulation::streaming::tests::timeline_invalidation_discards_queued_and_already_dequeued_framestimeline_invalidation_seria…app-emulation · cc 1cre8_app_emulation::streaming::tests::timeline_invalidation_serializes_with_an_in_progress_deliveryactual_session_restore_inva…app-emulation · cc 1cre8_app_emulation::streaming::tests::actual_session_restore_invalidates_stream_only_after_successfailed_socket_delivery_shut…app-emulation · cc 1cre8_app_emulation::streaming::tests::failed_socket_delivery_shuts_down_before_timeline_invalidationsubscribeapp-emulation · cc 1cre8_app_emulation::streaming::subscribesubscribe_sessionapp-emulation · cc 3cre8_app_emulation::streaming::subscribe_sessionregister_subscriberapp-emulation · cc 2cre8_app_emulation::streaming::register_subscribermailboxapp-emulation · cc 1cre8_app_emulation::streaming::buffer::mailbox

Control flow

Source not readable from this process.

Callers 2

Callees 1

Source not readable from this process.