Struct wick_packet::StreamMap

pub struct StreamMap { /* private fields */ }

A wrapper for a map of Strings to PacketStreams.

Implementations

impl StreamMap

pub fn take(&mut self, key: &str) -> Result<PacketStream, Error>

Remove a stream from the map by key name.

pub fn keys(&self) -> impl Iterator<Item = &String>

Get the keys in the map.

pub async fn next_for(&mut self, key: &str) -> Option<Result<Packet, Error>>

Take the next packet from the stream keyed by key.

pub async fn next_set( &mut self ) -> Result<Option<HashMap<String, Packet>>, Error>

Take one packet from each stream in the map. Returns an error if a complete set can’t be made.

pub fn init(&mut self, port: &str) -> PacketSender

Trait Implementations

impl Debug for StreamMap

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for StreamMap

fn default() -> StreamMap

Returns the “default value” for a type.

impl IntoIterator for StreamMap

type Item = (String, PacketStream)

The type of the elements being iterated over.

type IntoIter = IntoIter<String, PacketStream>

Which kind of iterator are we turning this into?

fn into_iter(self) -> Self::IntoIter

Creates an iterator from a value.