rust 1,859,989 · typescript 235,537 · javascript 132,952 · python 20,426 · 6,407 files · digest 4f42637fac12 · built in 1.2 s · crystals off
crates/cre8-app-messaging/src/call/stream/run.rs
Items
const FAILURE_LINE const CLASSIFY_MAX_TOKENS trait StreamServices trait CallStore enum SocketRead trait MediaSocket enum WorkerResult struct SpokenTurn struct Moved struct StreamRun static ACTIVE impl Drop for StreamRun impl StreamRun struct ProviderServices impl ProviderServices impl StreamServices for ProviderServices struct RuntimeCallStore impl RuntimeCallStore impl CallStore for RuntimeCallStore const CALL const STREAM const SECRET struct MemoryStore impl CallStore for MemoryStore struct FakeServices impl StreamServices for FakeServices struct Call impl Call
Functions
By call-graph weight (PageRank; 1.0 is the average function). 50 functions in all.
| function | kind | lines | cyclomatic | callers | callees | weight | crystal |
|---|---|---|---|---|---|---|---|
| StreamRun::spawnsrc/call/stream/run.rs:546 | method | 8 | 2 | 2 | 0 | 1.3 | |
| StreamRun::start_replysrc/call/stream/run.rs:343 | method | 39 | 6 | 1 | 4 | 1.3 | |
| Call::sentsrc/call/stream/run.rs:864 | method | 7 | 2 | 3 | 0 | 1.3 | |
| StreamRun::on_framesrc/call/stream/run.rs:218 | method | 21 | 7 | 6 | 5 | 1.2 | |
| call_statesrc/call/stream/run.rs:730 | fn | 39 | 1 | 1 | 0 | 1.1 | |
| StreamRun::next_replysrc/call/stream/run.rs:334 | method | 8 | 5 | 3 | 1 | 1 | |
| StreamRun::pumpsrc/call/stream/run.rs:241 | method | 22 | 8 | 3 | 5 | 0.9 | |
| Call::startsrc/call/stream/run.rs:823 | method | 10 | 1 | 5 | 7 | 0.9 | |
| Call::nowsrc/call/stream/run.rs:834 | method | 3 | 1 | 2 | 0 | 0.9 | |
| StreamRun::closesrc/call/stream/run.rs:264 | method | 4 | 1 | 2 | 0 | 0.9 | |
| Call::audiosrc/call/stream/run.rs:839 | method | 12 | 3 | 4 | 4 | 0.9 | |
| StreamRun::newsrc/call/stream/run.rs:160 | method | 31 | 1 | 4 | 2 | 0.8 | |
| active_callssrc/call/stream/run.rs:142 | fn | 4 | 1 | 2 | 0 | 0.8 | |
| reply_worksrc/call/stream/run.rs:558 | fn | 31 | 3 | 1 | 3 | 0.8 | |
| Call::markssrc/call/stream/run.rs:872 | method | 3 | 1 | 3 | 1 | 0.8 | |
| media_framesrc/call/stream/run.rs:786 | fn | 6 | 1 | 2 | 0 | 0.7 | |
| framesrc/call/stream/run.rs:798 | fn | 13 | 3 | 2 | 0 | 0.7 | |
| StreamRun::admit_startsrc/call/stream/run.rs:271 | method | 33 | 8 | 1 | 8 | 0.7 | |
| fakesrc/call/stream/run.rs:726 | fn | 3 | 1 | 3 | 0 | 0.7 | |
| storesrc/call/stream/run.rs:770 | fn | 3 | 1 | 3 | 1 | 0.7 | |
| start_framesrc/call/stream/run.rs:774 | fn | 11 | 1 | 3 | 0 | 0.7 | |
| mark_framesrc/call/stream/run.rs:793 | fn | 3 | 1 | 1 | 0 | 0.7 | |
| StreamRun::settle_unspokensrc/call/stream/run.rs:467 | method | 14 | 5 | 1 | 0 | 0.7 | |
| StreamRun::synthesizesrc/call/stream/run.rs:482 | method | 17 | 4 | 1 | 1 | 0.7 | |
| Call::playsrc/call/stream/run.rs:853 | method | 9 | 2 | 2 | 3 | 0.7 | |
| StreamRun::on_eventsrc/call/stream/run.rs:305 | method | 28 | 7 | 1 | 6 | 0.7 | |
| StreamRun::on_resultsrc/call/stream/run.rs:383 | method | 26 | 6 | 1 | 4 | 0.7 | |
| StreamRun::reply_readysrc/call/stream/run.rs:410 | method | 55 | 7 | 1 | 3 | 0.6 | |
| StreamRun::drivesrc/call/stream/run.rs:193 | method | 23 | 8 | 1 | 3 | 0.6 | |
| ProviderServices::newsrc/call/stream/run.rs:596 | method | 3 | 1 | 1 | 1 | 0.6 | |
| RuntimeCallStore::newsrc/call/stream/run.rs:649 | method | 3 | 1 | 1 | 0 | 0.6 | |
| StreamRun::turn_finishedsrc/call/stream/run.rs:501 | method | 44 | 13 | 1 | 2 | 0.6 | |
| StreamRun::dropsrc/call/stream/run.rs:148 | trait impl | 8 | 3 | 0 | 2 | 0.5 | |
| ProviderServices::transcribesrc/call/stream/run.rs:602 | trait impl | 8 | 1 | 0 | 1 | 0.5 | |
| ProviderServices::synthesizesrc/call/stream/run.rs:611 | trait impl | 13 | 1 | 0 | 4 | 0.5 | |
| ProviderServices::classifysrc/call/stream/run.rs:625 | trait impl | 16 | 1 | 0 | 1 | 0.5 | |
| RuntimeCallStore::loadsrc/call/stream/run.rs:655 | trait impl | 3 | 1 | 0 | 1 | 0.5 | |
| RuntimeCallStore::updatesrc/call/stream/run.rs:659 | trait impl | 10 | 1 | 0 | 5 | 0.5 | |
| MemoryStore::loadsrc/call/stream/run.rs:689 | trait impl | 3 | 1 | 0 | 0 | 0.5 | |
| MemoryStore::updatesrc/call/stream/run.rs:693 | trait impl | 6 | 1 | 0 | 0 | 0.5 | |
| FakeServices::transcribesrc/call/stream/run.rs:708 | trait impl | 3 | 1 | 0 | 0 | 0.5 | |
| FakeServices::synthesizesrc/call/stream/run.rs:712 | trait impl | 7 | 2 | 0 | 0 | 0.5 | |
| FakeServices::classifysrc/call/stream/run.rs:720 | trait impl | 4 | 1 | 0 | 0 | 0.5 | |
| Call::statesrc/call/stream/run.rs:876 | method | 3 | 1 | 0 | 0 | 0.5 | |
| unverified_streams_process_no_audiosrc/call/stream/run.rs:882 | fn | 34 | 1 | 0 | 12 | 0.5 | |
| separate_tokens_cannot_open_parallel_cursors_for_one_callsrc/call/stream/run.rs:918 | fn | 11 | 1 | 0 | 9 | 0.5 | |
| a_heard_reply_commits_the_cursor_and_finishes_its_claimsrc/call/stream/run.rs:931 | fn | 28 | 1 | 0 | 5 | 0.5 | |
| barge_in_after_part_of_the_reply_clears_it_and_commits_what_was_askedsrc/call/stream/run.rs:961 | fn | 14 | 1 | 0 | 5 | 0.5 | |
| a_reply_nobody_heard_rolls_the_cursor_backsrc/call/stream/run.rs:977 | fn | 12 | 1 | 0 | 4 | 0.5 | |
| an_invented_transition_ends_the_call_with_the_failure_linesrc/call/stream/run.rs:991 | fn | 13 | 1 | 0 | 5 | 0.5 |
Source not readable from this process.