| 38 | /// Internal Block reader. |
| 39 | #[derive(Debug, Clone)] |
| 40 | pub(super) struct Block<'r, R> { |
| 41 | reader: R, |
| 42 | /// Internal buffering to reduce allocation. |
| 43 | buf: Vec<u8>, |
| 44 | buf_idx: usize, |
| 45 | /// Number of elements expected to exist within this block. |
| 46 | message_count: usize, |
| 47 | marker: [u8; 16], |
| 48 | codec: Codec, |
| 49 | pub(super) writer_schema: Schema, |
| 50 | schemata: Vec<&'r Schema>, |
| 51 | pub(super) user_metadata: HashMap<String, Vec<u8>>, |
| 52 | names_refs: Names, |
| 53 | human_readable: bool, |
| 54 | } |
| 55 | |
| 56 | impl<'r, R: Read> Block<'r, R> { |
| 57 | pub(super) fn new( |
nothing calls this directly
no outgoing calls
no test coverage detected