Struct tinkerforge::converting_callback_receiver::ConvertingCallbackReceiver

pub struct ConvertingCallbackReceiver<T: FromByteSlice> { /* fields omitted */ }

A wrapper for Receiver, which converts received byte vectors to structured data. This variant of ConvertingReceiver is used for events.

This receiver wraps a Receiver receiving raw bytes. Calling recv_forever, recv_timeout or try_recv will call equivalent methods on the wrapped Receiver and then convert the received bytes to a instance of T.

Type parameters

• T - Type which is created from received byte vectors. Must implement FromByteSlice

Errors

Returned errors are equivalent to those returned from methods of a Receiver. If the received response can not be interpreted as the result type T, a MalformedPacket error is raised.

Implementations

impl<T: FromByteSlice> ConvertingCallbackReceiver<T>

pub fn new(receiver: Receiver<Vec<u8>>) -> ConvertingCallbackReceiver<T>

Creates a new converting callback receiver which wraps the given Receiver.

pub fn try_recv(&self) -> Result<T, CallbackTryRecvError>

Attempts to return a pending value on this receiver without blocking. This method behaves like try_recv.

Errors

Returns an error if the queue was disconnected or currently empty, or if the received packet was malformed.

pub fn recv_forever(&self) -> Result<T, CallbackRecvError>

Attempts to wait for a value on this receiver, returning an error if the corresponding channel has hung up. This method behaves like recv.

Errors

Returns an error if the queue was disconnected or currently empty, or if the received packet was malformed.

pub fn recv_timeout(
    &self,
    timeout: Duration
) -> Result<T, CallbackRecvTimeoutError>

Attempts to wait for a value on this receiver, returning an error if the corresponding channel has hung up, or if it waits more than timeout. This method behaves like recv_timeout.

Errors

Returns an error on one of the following conditions:

• The queue was disconnected.
• The received packet was malformed.
• Blocked longer than the configured time out.

pub fn iter(&self) -> Iter<T>

pub fn try_iter(&self) -> TryIter<T>

Trait Implementations

impl<'a, T: FromByteSlice> IntoIterator for &'a ConvertingCallbackReceiver<T>

type Item = T

The type of the elements being iterated over.

type IntoIter = Iter<'a, T>

Which kind of iterator are we turning this into?

fn into_iter(self) -> Iter<'a, T>

Creates an iterator from a value.

impl<T: FromByteSlice> IntoIterator for ConvertingCallbackReceiver<T>

type Item = T

The type of the elements being iterated over.

type IntoIter = IntoIter<T>

Which kind of iterator are we turning this into?

fn into_iter(self) -> IntoIter<T>

Creates an iterator from a value.