Skip to content
1 viewer

rust 1,859,989 · typescript 235,245 · javascript 132,952 · python 20,426 · 6,406 files · digest 386394835379 · built in 1.3 s · crystals off

run_with

cre8_app_messaging::send_batch::run_with

fn · cre8-app-messaging · crates/cre8-app-messaging/src/send_batch.rs:238 documented

131lines
16cyclomatic
3max nesting
55statements
5? exits
4params
4callers
17callees
1.2 (p85)call-graph weight

Crystal

no crystal was derived for this function

Call neighbourhood

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

name · 1 sitename · 7 sitesname · 1 sitename · 1 sitename · 2 sitesname · 2 sitesname · 1 sitename · 1 sitename · 2 sitesname · 1 sitename · 1 sitename · 1 sitepath · 1 sitepath · 1 sitemethod · 1 sitename · 1 sitename · 1 sitename · 1 sitename · 1 sitepath · 1 sitepath · 1 sitepath · 1 sitepath · 1 sitepath · 1 sitepath · 1 sitepath · 1 sitename · 1 sitename · 1 sitename · 1 sitename · 1 sitename · 1 sitemethod · 1 sitename · 1 sitepath · 1 sitemethod · 1 sitename · 1 sitemethod · 1 sitemethod · 1 sitemethod · 1 sitepath · 2 sitespath · 1 sitename · 1 sitedispatch_actionapp-messaging · cc 2cre8_app_messaging::send_batch::dispatch_actionunverified_streams_process_…app-messaging · cc 1cre8_app_messaging::call::stream::run::tests::unverified_streams_process_no_audioa_large_batch_chunks_at_one…app-messaging · cc 4cre8_app_messaging::send_batch::tests::a_large_batch_chunks_at_one_thousand_and_never_sends_to_a_suppressed_recipienteach_recipient_gets_its_own…app-messaging · cc 1cre8_app_messaging::send_batch::tests::each_recipient_gets_its_own_personalization_and_unsubscribe_linka_retried_batch_replays_rec…app-messaging · cc 1cre8_app_messaging::send_batch::tests::a_retried_batch_replays_recipients_it_already_reacheda_list_send_honors_the_list…app-messaging · cc 1cre8_app_messaging::send_batch::tests::a_list_send_honors_the_lists_opt_outs_and_its_links_leave_the_lista_body_that_shows_the_unsub…app-messaging · cc 2cre8_app_messaging::send_batch::tests::a_body_that_shows_the_unsubscribe_link_gets_each_recipients_ownan_unknown_provider_is_refu…app-messaging · cc 1cre8_app_messaging::send_batch::tests::an_unknown_provider_is_refused_before_anything_is_sentrunapp-messaging · cc 2cre8_app_messaging::send_batch::runrun_capturingapp-messaging · cc 1cre8_app_messaging::send_batch::tests::run_capturinginvalid_and_duplicate_recip…app-messaging · cc 1cre8_app_messaging::send_batch::tests::invalid_and_duplicate_recipients_are_reported_and_a_failed_request_fails_its_chunka_provider_that_answers_per…app-messaging · cc 2cre8_app_messaging::send_batch::tests::a_provider_that_answers_per_recipient_fails_only_the_refused_onesrun_withapp-messaging · cc 16cre8_app_messaging::send_batch::run_withvarplatform-env · cc 1cre8_platform_env::varnormalize_addressapp-messaging · cc 2cre8_app_messaging::suppression::normalize_addressSendScope::from_senderapp-messaging · cc 2cre8_app_messaging::suppression::SendScope::from_senderreserve_callapp-messaging · cc 5cre8_app_messaging::budget::reserve_callnormalize_scopeapp-messaging · cc 3cre8_app_messaging::suppression::normalize_scopeurl_forapp-messaging · cc 1cre8_app_messaging::unsubscribe::url_forheader_pairapp-messaging · cc 2cre8_app_messaging::unsubscribe::header_pairomission_reasonapp-messaging · cc 3cre8_app_messaging::unsubscribe::omission_reasonpersist_tallyapp-messaging · cc 2cre8_app_messaging::budget::persist_tallysummaryapp-messaging · cc 1cre8_app_messaging::send_batch::summaryBatchRequest::mentions_unsu…app-messaging · cc 1cre8_app_messaging::send_batch::BatchRequest::mentions_unsubscribe_linkrecipient_keyapp-messaging · cc 2cre8_app_messaging::send_batch::recipient_keyblocking_suppressionapp-messaging · cc 3cre8_app_messaging::send_batch::blocking_suppressionreplay_sentapp-messaging · cc 2cre8_app_messaging::send_batch::replay_sentvar_optplatform-env · cc 2cre8_platform_env::var_optMutex::lock_or_recoverutil-lock-ext · cc 2cre8_util_lock_ext::Mutex::lock_or_recoverHyperDbProtocolStore::graph…app-protocol · cc 1cre8_app_protocol::store_adapter::HyperDbProtocolStore::graph_mutDurableGraphWrite::update_v…app-atom · cc 1cre8_app_atom::semantic::DurableGraphWrite::update_vertexRuntimeContext::with_protoc…app-protocol · cc 1cre8_app_protocol::context_ext::RuntimeContext::with_protocol_store_mut_optstrip_display_nameapp-messaging · cc 3cre8_app_messaging::suppression::strip_display_namenormalize_dialableapp-messaging · cc 3cre8_app_messaging::suppression::normalize_dialablefindapp-messaging · cc 3cre8_app_messaging::suppression::findfind_by_idempotencyapp-messaging · cc 2cre8_app_messaging::store::find_by_idempotencybudget_stateapp-messaging · cc 1cre8_app_messaging::budget::budget_state

Control flow

Source not readable from this process.

Callees 17

Source not readable from this process.