pub fn stream_take(
stream: &StreamValue,
limit: usize,
) -> Result<Vec<StreamItem>>Expand description
stream/take: pulls up to limit packets from stream.
pub fn stream_take(
stream: &StreamValue,
limit: usize,
) -> Result<Vec<StreamItem>>stream/take: pulls up to limit packets from stream.