rust 1,961,941 · typescript 233,850 · javascript 141,145 · python 22,871 · 6,801 files · digest 6d882eacc8db · built in 12.5 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.8 | |
| 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.6 | |
| StreamRun::on_resultsrc/call/stream/run.rs:383 | method | 26 | 6 | 1 | 4 | 0.6 | |
| 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.