Struct market::io::Reader

pub struct Reader<G: AssembleFrom<u8>> { /* fields omitted */ }

Consumes goods of type G assembled from bytes read by a Read trait object.

Because Read::read() does not provide any guarantees about blocking, the read is executed in a separate thread which produces the read bytes. The current thread attempts to assemble the consumed bytes into a good.

Implementations

impl<G: AssembleFrom<u8>> Reader<G>

pub fn new<R>(description: String, mut reader: R) -> Self where
    R: Read + RefUnwindSafe + Send + 'static, 

Creates a new Reader with reader.

pub fn cancel(&self)

Requests that the thread be canceled.

Trait Implementations

impl<G: AssembleFrom<u8>> Consumer for Reader<G> where
    <G as AssembleFrom<u8>>::Error: TryFrom<ConsumeFailure<<G as AssembleFrom<u8>>::Error>>, 

type Good = G

The item being consumed.

type Failure = ConsumeFailure<ReadFault<G>>

Describes a failure to successfully complete consumption.

fn consume(&self) -> Result<Self::Good, Self::Failure>

Retrieves the next good from the market without blocking.

fn goods(&self) -> Goods<'_, Self> where
    Self: Sized, 

Returns a Goods of self.

fn demand(&self) -> Result<Self::Good, <Self::Failure as Failure>::Fault>

Retrieves the next good from the market, blocking until one is available.

impl<G: Debug + AssembleFrom<u8>> Debug for Reader<G>

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

Formats the value using the given formatter.