Searched refs:HostStreamConsumer (Results 1 – 1 of 1) sorted by relevance
820 stream.pipe(&mut s, HostStreamConsumer(id, arc)).unwrap(); in ensure_stream_reading()938 struct HostStreamConsumer(u32, #[expect(dead_code, reason = "drop-tracking")] Arc<()>); struct961 impl StreamConsumer<Data> for HostStreamConsumer { implementation1025 impl Drop for HostStreamConsumer { implementation