1 viewer
rust 1,859,748 · typescript 235,215 · javascript 132,950 · python 20,426 · 6,405 files · digest 9ba5c926519d · built in 1.7 s · crystals off
crates/cre8-app-conduit/src/streaming/http_audio_stream.rs
Items
type AudioChunk type AudioChunkChannel type AudioChunkReceiver type AudioListenerLease struct AudioHttpHeaderSpec struct ConduitAudioRequestOptions struct OpusAudioRequest struct PcmAudioRequestOptions struct PreparedConduitAudioStream struct OggPacketPage struct OggOpusSegmentRewriter impl OggOpusSegmentRewriter struct WavAudioEncodeOutput struct FlacAudioEncodeOutput const MP3_PCM_HEADROOM_PEAK struct Mp3AudioEncodeOutput struct Mp3AtomOutput struct I16ResampleFrameSpec struct Mp3StreamStats impl Mp3StreamStats struct Mp3LiveEncoder impl Mp3LiveEncoder struct Mp3TransportWrite enum Mp3TransportError impl Mp3TransportError enum Mp3StreamPhase enum Mp3ReplayResult enum FiniteFlacSource enum FiniteFlacChunk enum FiniteFlacCollectStep enum FlacStreamChunkStatus enum FlacStreamLoopStep struct WavAudioRequestOptions enum FiniteWavSource enum FiniteWavChunk enum FiniteWavCollectStep
Functions
By call-graph weight (PageRank; 1.0 is the average function). 140 functions in all.
| function | kind | lines | cyclomatic | callers | callees | weight | crystal |
|---|---|---|---|---|---|---|---|
| resample_interleaved_i16src/streaming/http_audio_stream.rs:1055 | fn | 44 | 10 | 12 | 2 | 3.6 | |
| write_http_chunksrc/streaming/http_audio_stream.rs:25 | fn | 6 | 1 | 5 | 0 | 3.1 | |
| is_pcm_s16le_audio_chunksrc/streaming/http_audio_stream.rs:584 | fn | 3 | 1 | 11 | 1 | 2.5 | |
| resampled_output_framessrc/streaming/http_audio_stream.rs:1109 | fn | 5 | 1 | 1 | 0 | 2 | |
| push_resampled_frame_i16src/streaming/http_audio_stream.rs:1115 | fn | 11 | 2 | 1 | 2 | 2 | |
| respond_audio_data_responsesrc/streaming/http_audio_stream.rs:80 | fn | 21 | 2 | 5 | 2 | 1.9 | |
| finish_http_chunkssrc/streaming/http_audio_stream.rs:32 | fn | 4 | 1 | 6 | 0 | 1.7 | |
| flush_flac_stream_tailsrc/streaming/http_audio_stream.rs:1985 | fn | 6 | 2 | 3 | 0 | 1.6 | |
| apply_mp3_pcm_headroomsrc/streaming/http_audio_stream.rs:763 | fn | 10 | 3 | 4 | 1 | 1.6 | |
| streaming_connection_headersrc/streaming/http_audio_stream.rs:46 | fn | 3 | 2 | 4 | 0 | 1.6 | |
| write_audio_http_headersrc/streaming/http_audio_stream.rs:50 | fn | 29 | 4 | 4 | 0 | 1.6 | |
| pcm_i16_samplessrc/streaming/http_audio_stream.rs:1127 | fn | 3 | 1 | 7 | 0 | 1.5 | |
| mp3_encoder_sample_rate_for_pcmsrc/streaming/http_audio_stream.rs:749 | fn | 9 | 2 | 3 | 0 | 1.4 | |
| resampled_channel_samplesrc/streaming/http_audio_stream.rs:1021 | fn | 33 | 6 | 1 | 0 | 1.4 | |
| Mp3StreamStats::record_response_bytessrc/streaming/http_audio_stream.rs:1359 | method | 6 | 2 | 2 | 0 | 1.3 | |
| OggOpusSegmentRewriter::write_pagesrc/streaming/http_audio_stream.rs:526 | method | 14 | 1 | 2 | 0 | 1.3 | |
| flush_mp3_encoder_streamsrc/streaming/http_audio_stream.rs:909 | fn | 14 | 2 | 4 | 1 | 1.3 | |
| pcm_i16_bytessrc/streaming/http_audio_stream.rs:1131 | fn | 3 | 1 | 5 | 0 | 1.2 | |
| write_pcm_chunk_as_mp3_streamsrc/streaming/http_audio_stream.rs:993 | fn | 27 | 4 | 3 | 7 | 1.2 | |
| handle_flac_stream_recvsrc/streaming/http_audio_stream.rs:2044 | fn | 28 | 3 | 1 | 4 | 1 | |
| handle_finite_flac_recvsrc/streaming/http_audio_stream.rs:1795 | fn | 19 | 4 | 1 | 2 | 1 | |
| parse_conduit_audio_request_optionssrc/streaming/http_audio_stream.rs:130 | fn | 17 | 1 | 5 | 3 | 1 | |
| handle_finite_wav_recvsrc/streaming/http_audio_stream.rs:2299 | fn | 19 | 4 | 1 | 2 | 1 | |
| OggOpusSegmentRewriter::newsrc/streaming/http_audio_stream.rs:509 | method | 16 | 2 | 4 | 1 | 1 | |
| OggOpusSegmentRewriter::rewrite_chunksrc/streaming/http_audio_stream.rs:563 | method | 15 | 3 | 4 | 4 | 1 | |
| respond_flac_native_unavailablesrc/streaming/http_audio_stream.rs:1717 | fn | 16 | 2 | 2 | 1 | 0.9 | |
| finite_flac_collect_should_stopsrc/streaming/http_audio_stream.rs:1761 | fn | 3 | 2 | 1 | 1 | 0.9 | |
| handle_finite_flac_chunksrc/streaming/http_audio_stream.rs:1776 | fn | 18 | 4 | 1 | 2 | 0.9 | |
| finite_wav_collect_should_stopsrc/streaming/http_audio_stream.rs:2265 | fn | 3 | 2 | 1 | 1 | 0.9 | |
| handle_finite_wav_chunksrc/streaming/http_audio_stream.rs:2280 | fn | 18 | 4 | 1 | 2 | 0.9 | |
| audio_chunk_with_formatsrc/streaming/http_audio_stream.rs:2693 | fn | 12 | 1 | 2 | 0 | 0.9 | |
| pcm_chunksrc/streaming/http_audio_stream.rs:1209 | fn | 18 | 2 | 3 | 0 | 0.9 | |
| classify_finite_flac_chunksrc/streaming/http_audio_stream.rs:1751 | fn | 9 | 5 | 1 | 2 | 0.9 | |
| push_finite_flac_pcm_chunksrc/streaming/http_audio_stream.rs:1765 | fn | 10 | 1 | 1 | 0 | 0.9 | |
| classify_finite_wav_chunksrc/streaming/http_audio_stream.rs:2255 | fn | 9 | 5 | 1 | 2 | 0.9 | |
| push_finite_wav_pcm_chunksrc/streaming/http_audio_stream.rs:2269 | fn | 10 | 1 | 1 | 0 | 0.9 | |
| is_flac_audio_chunksrc/streaming/http_audio_stream.rs:588 | fn | 3 | 1 | 1 | 0 | 0.9 | |
| ogg_packet_pagessrc/streaming/http_audio_stream.rs:459 | fn | 35 | 6 | 3 | 0 | 0.9 | |
| is_wav_audio_chunksrc/streaming/http_audio_stream.rs:592 | fn | 3 | 1 | 1 | 0 | 0.9 | |
| respond_too_many_audio_listenerssrc/streaming/http_audio_stream.rs:102 | fn | 17 | 1 | 2 | 1 | 0.8 | |
| open_conduit_audio_channelsrc/streaming/http_audio_stream.rs:172 | fn | 7 | 2 | 2 | 2 | 0.8 | |
| mp3_stream_encoder_shapesrc/streaming/http_audio_stream.rs:925 | fn | 3 | 1 | 2 | 2 | 0.8 | |
| is_ogg_opus_audio_chunksrc/streaming/http_audio_stream.rs:445 | fn | 3 | 1 | 2 | 1 | 0.8 | |
| encode_pcm_chunks_to_mp3_bytessrc/streaming/http_audio_stream.rs:786 | fn | 52 | 10 | 2 | 6 | 0.8 | |
| prepare_conduit_audio_streamsrc/streaming/http_audio_stream.rs:180 | fn | 34 | 4 | 4 | 6 | 0.8 | |
| is_mp3_audio_chunksrc/streaming/http_audio_stream.rs:580 | fn | 3 | 1 | 2 | 1 | 0.8 | |
| stream_native_conduit_flac_responsesrc/streaming/http_audio_stream.rs:2112 | fn | 43 | 4 | 1 | 5 | 0.8 | |
| flac_encoder_configsrc/streaming/http_audio_stream.rs:672 | fn | 8 | 1 | 2 | 0 | 0.8 | |
| opus_stream_payloadsrc/streaming/http_audio_stream.rs:2557 | fn | 17 | 3 | 1 | 3 | 0.8 | |
| write_counted_opus_payloadsrc/streaming/http_audio_stream.rs:2575 | fn | 15 | 4 | 1 | 1 | 0.8 | |
| process_live_mp3_chunksrc/streaming/http_audio_stream.rs:1567 | fn | 19 | 2 | 1 | 4 | 0.7 | |
| start_opus_station_from_requestsrc/streaming/http_audio_stream.rs:353 | fn | 6 | 2 | 1 | 1 | 0.7 | |
| respond_finite_conduit_flac_responsesrc/streaming/http_audio_stream.rs:1881 | fn | 17 | 3 | 1 | 5 | 0.7 | |
| stream_conduit_flac_responsesrc/streaming/http_audio_stream.rs:2156 | fn | 18 | 1 | 1 | 2 | 0.7 | |
| respond_single_conduit_opus_chunksrc/streaming/http_audio_stream.rs:2451 | fn | 79 | 8 | 1 | 6 | 0.7 | |
| stream_conduit_opus_chunkssrc/streaming/http_audio_stream.rs:2608 | fn | 53 | 7 | 1 | 5 | 0.7 | |
| write_flac_stream_chunksrc/streaming/http_audio_stream.rs:1957 | fn | 26 | 6 | 1 | 4 | 0.7 | |
| handle_flac_stream_chunk_statussrc/streaming/http_audio_stream.rs:1993 | fn | 26 | 6 | 1 | 1 | 0.7 | |
| handle_flac_stream_timeoutsrc/streaming/http_audio_stream.rs:2021 | fn | 21 | 3 | 1 | 2 | 0.7 | |
| Mp3StreamStats::record_transport_writesrc/streaming/http_audio_stream.rs:1352 | method | 6 | 2 | 2 | 1 | 0.7 | |
| Mp3StreamStats::reached_source_limitsrc/streaming/http_audio_stream.rs:1366 | method | 3 | 2 | 2 | 0 | 0.7 | |
| write_mp3_transport_chunksrc/streaming/http_audio_stream.rs:1471 | fn | 22 | 4 | 2 | 6 | 0.7 | |
| log_mp3_transport_errorsrc/streaming/http_audio_stream.rs:1494 | fn | 18 | 5 | 2 | 0 | 0.7 | |
| is_opus_header_packetsrc/streaming/http_audio_stream.rs:495 | fn | 3 | 2 | 1 | 0 | 0.7 | |
| OggOpusSegmentRewriter::write_headerssrc/streaming/http_audio_stream.rs:541 | method | 21 | 2 | 1 | 1 | 0.7 | |
| collect_resampled_pcm_samplessrc/streaming/http_audio_stream.rs:652 | fn | 18 | 4 | 1 | 3 | 0.7 | |
| decode_http_chunkssrc/streaming/http_audio_stream.rs:1228 | fn | 20 | 3 | 2 | 0 | 0.7 | |
| pcm_stream_payloadsrc/streaming/http_audio_stream.rs:243 | fn | 9 | 2 | 1 | 4 | 0.7 | |
| write_counted_pcm_stream_payloadsrc/streaming/http_audio_stream.rs:253 | fn | 8 | 3 | 1 | 0 | 0.7 | |
| mp3_stream_encoder_configsrc/streaming/http_audio_stream.rs:930 | fn | 12 | 3 | 1 | 0 | 0.7 | |
| encode_streaming_pcm_chunks_to_flac_bytessrc/streaming/http_audio_stream.rs:682 | fn | 28 | 5 | 1 | 5 | 0.7 | |
| encode_finite_pcm_chunks_to_flac_bytessrc/streaming/http_audio_stream.rs:712 | fn | 19 | 2 | 1 | 3 | 0.7 | |
| opus_test_chunksrc/streaming/http_audio_stream.rs:2680 | fn | 12 | 1 | 2 | 0 | 0.7 | |
| ogg_pagesrc/streaming/http_audio_stream.rs:2722 | fn | 3 | 1 | 2 | 0 | 0.7 | |
| write_pcm_stream_headersrc/streaming/http_audio_stream.rs:223 | fn | 19 | 1 | 1 | 2 | 0.7 | |
| handle_pcm_stream_recvsrc/streaming/http_audio_stream.rs:262 | fn | 28 | 4 | 1 | 3 | 0.7 | |
| ensure_mp3_stream_encodersrc/streaming/http_audio_stream.rs:944 | fn | 27 | 3 | 1 | 3 | 0.6 | |
| write_mp3_stream_sample_batchessrc/streaming/http_audio_stream.rs:973 | fn | 18 | 3 | 1 | 1 | 0.6 | |
| write_flac_stream_headersrc/streaming/http_audio_stream.rs:1899 | fn | 26 | 1 | 1 | 2 | 0.6 | |
| create_flac_stream_encodersrc/streaming/http_audio_stream.rs:1927 | fn | 14 | 1 | 1 | 0 | 0.6 | |
| run_flac_stream_loopsrc/streaming/http_audio_stream.rs:2074 | fn | 36 | 2 | 1 | 1 | 0.6 | |
| encode_pcm_chunks_to_flac_bytessrc/streaming/http_audio_stream.rs:733 | fn | 14 | 2 | 1 | 3 | 0.6 | |
| encode_pcm_chunks_to_wav_bytessrc/streaming/http_audio_stream.rs:604 | fn | 37 | 5 | 1 | 5 | 0.6 | |
| wav_output_audio_shapesrc/streaming/http_audio_stream.rs:2189 | fn | 15 | 1 | 1 | 1 | 0.6 | |
| respond_wav_encode_errorsrc/streaming/http_audio_stream.rs:2351 | fn | 11 | 1 | 1 | 1 | 0.6 | |
| respond_flac_pcm_unavailablesrc/streaming/http_audio_stream.rs:1734 | fn | 11 | 1 | 1 | 1 | 0.6 | |
| respond_flac_passthrough_responsesrc/streaming/http_audio_stream.rs:1746 | fn | 4 | 1 | 1 | 1 | 0.6 | |
| collect_finite_flac_sourcesrc/streaming/http_audio_stream.rs:1815 | fn | 19 | 4 | 1 | 1 | 0.6 | |
| respond_encoded_flac_responsesrc/streaming/http_audio_stream.rs:1835 | fn | 45 | 2 | 1 | 4 | 0.6 | |
| write_opus_stream_headersrc/streaming/http_audio_stream.rs:2531 | fn | 25 | 2 | 1 | 2 | 0.6 | |
| handle_opus_stream_chunksrc/streaming/http_audio_stream.rs:2591 | fn | 16 | 3 | 1 | 2 | 0.6 | |
| handle_conduit_audio_pcm_requestsrc/streaming/http_audio_stream.rs:431 | fn | 13 | 1 | 1 | 6 | 0.6 | |
| handle_conduit_audio_mp3_requestsrc/streaming/http_audio_stream.rs:1329 | fn | 14 | 1 | 1 | 6 | 0.6 | |
| handle_conduit_audio_flac_requestsrc/streaming/http_audio_stream.rs:1674 | fn | 23 | 3 | 1 | 9 | 0.6 | |
| handle_conduit_audio_wav_requestsrc/streaming/http_audio_stream.rs:2409 | fn | 13 | 1 | 1 | 6 | 0.6 | |
| handle_conduit_audio_opus_requestsrc/streaming/http_audio_stream.rs:2423 | fn | 27 | 6 | 1 | 9 | 0.6 | |
| Mp3LiveEncoder::pcm_transport_enabledsrc/streaming/http_audio_stream.rs:1388 | method | 3 | 1 | 1 | 0 | 0.6 | |
| Mp3LiveEncoder::write_pcmsrc/streaming/http_audio_stream.rs:1392 | method | 11 | 1 | 1 | 1 | 0.6 | |
| Mp3LiveEncoder::clear_config_after_passthroughsrc/streaming/http_audio_stream.rs:1416 | method | 6 | 1 | 1 | 0 | 0.6 | |
| respond_direct_wav_chunksrc/streaming/http_audio_stream.rs:2205 | fn | 8 | 1 | 1 | 1 | 0.6 | |
| collect_finite_wav_sourcesrc/streaming/http_audio_stream.rs:2319 | fn | 19 | 4 | 1 | 1 | 0.6 | |
| respond_wav_pcm_unavailablesrc/streaming/http_audio_stream.rs:2339 | fn | 11 | 1 | 1 | 1 | 0.6 | |
| respond_encoded_wav_responsesrc/streaming/http_audio_stream.rs:2363 | fn | 29 | 2 | 1 | 4 | 0.6 | |
| opus_autostart_requestedsrc/streaming/http_audio_stream.rs:318 | fn | 6 | 4 | 1 | 2 | 0.6 | |
| parse_pcm_audio_request_optionssrc/streaming/http_audio_stream.rs:215 | fn | 7 | 1 | 1 | 3 | 0.6 | |
| stream_conduit_pcm_responsesrc/streaming/http_audio_stream.rs:291 | fn | 26 | 3 | 1 | 3 | 0.6 | |
| stream_conduit_mp3_responsesrc/streaming/http_audio_stream.rs:1645 | fn | 28 | 4 | 1 | 6 | 0.6 | |
| parse_wav_audio_request_optionssrc/streaming/http_audio_stream.rs:2239 | fn | 15 | 1 | 1 | 4 | 0.6 | |
| respond_finite_conduit_wav_responsesrc/streaming/http_audio_stream.rs:2393 | fn | 15 | 3 | 1 | 5 | 0.6 | |
| Mp3LiveEncoder::newsrc/streaming/http_audio_stream.rs:1379 | method | 8 | 1 | 1 | 0 | 0.6 | |
| write_mp3_stream_headersrc/streaming/http_audio_stream.rs:1455 | fn | 15 | 1 | 1 | 2 | 0.6 | |
| replay_mp3_backlogsrc/streaming/http_audio_stream.rs:1532 | fn | 34 | 6 | 1 | 9 | 0.6 | |
| stream_live_mp3_chunkssrc/streaming/http_audio_stream.rs:1587 | fn | 45 | 6 | 1 | 2 | 0.6 | |
| finish_mp3_streamsrc/streaming/http_audio_stream.rs:1633 | fn | 11 | 3 | 1 | 1 | 0.6 | |
| parse_opus_audio_requestsrc/streaming/http_audio_stream.rs:325 | fn | 13 | 3 | 1 | 5 | 0.6 | |
| claim_audio_listener_or_respondsrc/streaming/http_audio_stream.rs:339 | fn | 13 | 2 | 1 | 2 | 0.6 | |
| maybe_start_opus_station_or_respondsrc/streaming/http_audio_stream.rs:360 | fn | 22 | 2 | 1 | 2 | 0.6 | |
| open_audio_channel_or_respondsrc/streaming/http_audio_stream.rs:383 | fn | 21 | 2 | 1 | 2 | 0.6 | |
| dispatch_conduit_opus_responsesrc/streaming/http_audio_stream.rs:405 | fn | 25 | 2 | 1 | 2 | 0.6 | |
| handle_conduit_flac_responsesrc/streaming/http_audio_stream.rs:2175 | fn | 13 | 2 | 1 | 2 | 0.6 | |
| Mp3TransportError::should_finish_replay_responsesrc/streaming/http_audio_stream.rs:1438 | method | 3 | 1 | 1 | 0 | 0.5 | |
| finish_limited_mp3_replaysrc/streaming/http_audio_stream.rs:1513 | fn | 18 | 3 | 1 | 2 | 0.5 | |
| encode_pcm_chunks_to_mp3_atomsrc/streaming/http_audio_stream.rs:854 | fn | 42 | 3 | 0 | 4 | 0.5 | |
| unsupported_pcm_rate_is_promoted_for_mp3_transportsrc/streaming/http_audio_stream.rs:1146 | fn | 5 | 1 | 0 | 1 | 0.5 | |
| resampler_preserves_interleaved_channelssrc/streaming/http_audio_stream.rs:1153 | fn | 9 | 1 | 0 | 1 | 0.5 | |
| resampler_downmixes_multichannel_without_reframingsrc/streaming/http_audio_stream.rs:1164 | fn | 5 | 1 | 0 | 1 | 0.5 | |
| resampler_upmixes_mono_to_stereosrc/streaming/http_audio_stream.rs:1171 | fn | 5 | 1 | 0 | 1 | 0.5 | |
| resampler_rejects_invalid_rates_and_channelssrc/streaming/http_audio_stream.rs:1178 | fn | 7 | 1 | 0 | 1 | 0.5 | |
| resampler_trims_partial_frames_on_passthroughsrc/streaming/http_audio_stream.rs:1187 | fn | 5 | 1 | 0 | 1 | 0.5 | |
| mp3_pcm_headroom_limits_full_scale_peakssrc/streaming/http_audio_stream.rs:1194 | fn | 7 | 1 | 0 | 1 | 0.5 | |
| mp3_pcm_headroom_leaves_quiet_samples_untouchedsrc/streaming/http_audio_stream.rs:1203 | fn | 5 | 1 | 0 | 1 | 0.5 | |
| mp3_stream_keeps_partial_pcm_across_chunkssrc/streaming/http_audio_stream.rs:1250 | fn | 22 | 1 | 0 | 4 | 0.5 | |
| finite_mp3_replay_flushes_short_pcm_chunk_at_source_limitsrc/streaming/http_audio_stream.rs:1274 | fn | 23 | 2 | 0 | 5 | 0.5 | |
| finite_mp3_encoder_skips_non_pcm_and_flushes_outputsrc/streaming/http_audio_stream.rs:1299 | fn | 19 | 1 | 0 | 2 | 0.5 | |
| Mp3LiveEncoder::flushsrc/streaming/http_audio_stream.rs:1404 | method | 11 | 1 | 0 | 1 | 0.5 | |
| http_chunk_writer_frames_payloadssrc/streaming/http_audio_stream.rs:2672 | fn | 7 | 1 | 0 | 2 | 0.5 | |
| mp3_transport_accepts_canonical_mime_aliasessrc/streaming/http_audio_stream.rs:2707 | fn | 6 | 2 | 0 | 2 | 0.5 | |
| pcm_transport_accepts_s16le_mime_aliasessrc/streaming/http_audio_stream.rs:2715 | fn | 6 | 2 | 0 | 2 | 0.5 | |
| opus_segment_rewriter_prepends_headers_to_continuation_pagessrc/streaming/http_audio_stream.rs:2727 | fn | 18 | 1 | 0 | 5 | 0.5 | |
| opus_segment_rewriter_replaces_source_headers_oncesrc/streaming/http_audio_stream.rs:2747 | fn | 27 | 1 | 0 | 5 | 0.5 |
Source not readable from this process.