Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/Tangent128/webmetro
/ functions
Functions
69 in github.com/Tangent128/webmetro
⨍
Functions
69
◇
Types & classes
27
↓ 16 callers
Function
encode_varint
Tries to write an EBML varint using minimal space
src/ebml.rs:118
↓ 11 callers
Function
decode_varint
Try to parse an EBML varint at the start of the given slice. Returns an Err() if the format is corrupt. Returns Ok(None) if more bytes are needed to g
src/ebml.rs:34
↓ 11 callers
Function
encode_webm_element
(element: WebmElement, output: &mut T)
src/webm.rs:116
↓ 10 callers
Function
decode_tag
Try to parse an EBML element header at the start of the given slice. Returns an Err() if the format is corrupt. Returns Ok(None) if more bytes are nee
src/ebml.rs:83
↓ 6 callers
Method
next
(&'a mut self)
src/stream_parser.rs:80
↓ 6 callers
Method
parse_ebml
(self)
src/stream_parser.rs:26
↓ 5 callers
Function
encode_tag_header
(tag: u64, size: Varint, output: &mut T)
src/ebml.rs:179
↓ 4 callers
Function
encode
(element: WebmElement, buffer: &mut Cursor<Vec<u8>>, limit: Option<usize>)
src/chunk.rs:130
↓ 4 callers
Function
run
(args: SendArgs)
src/commands/send.rs:39
↓ 3 callers
Method
chunk_webm
(self)
src/chunk.rs:252
↓ 3 callers
Function
decode_uint
(bytes: &[u8])
src/ebml.rs:105
↓ 3 callers
Method
process
(&mut self, mut chunk: Chunk)
src/fixers.rs:24
↓ 3 callers
Function
stdin_stream
An adapter that makes chunks of bytes from stdin available as a Stream; is NOT actually async, and just uses blocking read. Don't use more than one at
src/commands/mod.rs:16
↓ 3 callers
Method
update_timecode
(&mut self, timecode: u64)
src/chunk.rs:34
↓ 2 callers
Function
encode_bytes
Tries to write a simple EBML tag with a string or binary value
src/ebml.rs:185
↓ 2 callers
Function
encode_varint_4
tries to write a varint with a fixed 4-byte representation
src/ebml.rs:149
↓ 2 callers
Function
media_response
(body: Body)
src/commands/relay.rs:53
↓ 2 callers
Method
overlaps
(&self, start: u128, stop: u128)
src/chunk.rs:71
↓ 2 callers
Method
poll_event
( &'a mut self, cx: &mut Context, )
src/stream_parser.rs:43
↓ 2 callers
Method
with_soft_limit
add a "soft" buffer size limit; if a chunk buffer exceeds this size, error the stream instead of resuming. It's still possible for a buffer to exceed
src/chunk.rs:124
↓ 1 callers
Function
decode_simple_block
(bytes: &[u8])
src/webm.rs:71
↓ 1 callers
Function
ebml_iter
(source: &'a [u8])
src/iterator.rs:7
↓ 1 callers
Function
encode_element
(tag: u64, output: &mut T, content: F)
src/ebml.rs:164
↓ 1 callers
Function
encode_integer
Tries to write a simple EBML tag with an integer value
src/ebml.rs:191
↓ 1 callers
Function
encode_simple_block
(block: SimpleBlock, output: &mut T)
src/webm.rs:90
↓ 1 callers
Method
find_starting_point
(self)
src/fixers.rs:146
↓ 1 callers
Function
get_stream
(channel: Handle)
src/commands/relay.rs:25
↓ 1 callers
Method
observe_simpleblock_timecode
(&mut self, timecode: i16)
src/chunk.rs:47
↓ 1 callers
Function
parse_webm
(source: &'a T)
src/webm.rs:17
↓ 1 callers
Function
post_stream
( channel: Handle, stream: impl Stream<Item = Result<impl Buf, warp::Error>> + Unpin, )
src/commands/relay.rs:35
↓ 1 callers
Method
send
(&self, chunk: Chunk)
src/channel.rs:53
Function
async_webm_test
()
src/stream_parser.rs:173
Function
bad_uints
()
src/ebml.rs:393
Method
check_space
Check if enough space exists in the given buffer to decode an element; it will not actually call `decode` or try to construct an instance, but EBML er
src/ebml.rs:222
Method
decode
(element_id: u64, bytes: &'b[u8])
src/webm.rs:54
Method
decode
(element_id: u64, bytes: &'a[u8])
src/ebml.rs:421
Method
decode_element
Attempt to construct an instance of this type from the given byte slice
src/ebml.rs:251
Function
decode_sanity_test
()
src/ebml.rs:429
Function
decode_webm_test1
()
src/webm.rs:144
Method
drop
(&mut self)
src/channel.rs:37
Function
encode_varints
()
src/ebml.rs:298
Function
encode_webm_test
()
src/webm.rs:199
Function
enough_space_for_header
()
src/chunk.rs:267
Function
fail_corrupted_tags
()
src/ebml.rs:369
Function
fail_corrupted_varints
()
src/ebml.rs:273
Method
from
(message: &str)
src/error.rs:15
Function
incomplete_tags
()
src/ebml.rs:377
Function
incomplete_varints
()
src/ebml.rs:279
Function
main
()
src/main.rs:24
Method
new
(name: String)
src/channel.rs:26
Method
new
(timecode: u64)
src/chunk.rs:24
Method
new
()
src/fixers.rs:17
Method
next
(&mut self)
src/chunk.rs:83
Method
next
(&mut self)
src/iterator.rs:14
Function
parse_tags
()
src/ebml.rs:384
Function
parse_time
(arg: &str)
src/commands/mod.rs:20
Function
parse_uints
()
src/ebml.rs:399
Function
parse_varints
()
src/ebml.rs:286
Method
poll_next
(self: Pin<&mut Self>, cx: &mut Context)
src/channel.rs:108
Method
poll_next
(self: Pin<&mut Self>, cx: &mut Context)
src/chunk.rs:146
Method
poll_next
( mut self: Pin<&mut Self>, cx: &mut Context, )
src/fixers.rs:51
Function
run
(args: FilterArgs)
src/commands/filter.rs:29
Function
run
(_args: DumpArgs)
src/commands/dump.rs:15
Function
run
(args: RelayArgs)
src/commands/relay.rs:70
Method
should_unwrap
(element_id: u64)
src/webm.rs:45
Method
should_unwrap
(element_id: u64)
src/ebml.rs:415
Function
stream_webm_test
()
src/stream_parser.rs:121
Method
throttle
(self)
src/fixers.rs:154
Method
with_soft_limit
add a "soft" buffer size limit; if the input buffer exceeds this size, error the stream instead of resuming. It's still possible for the buffer to exc
src/stream_parser.rs:19