pub struct ConvertingReceiver<T: FromByteSlice> { /* private fields */ }
Expand description

A wrapper for Receiver, which converts received byte vectors to structured data.

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

§Note

Calling recv will not block indefinitely. Instead the timeout passed to the new method is used for a call of recv_timeout

§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. Additionally errors raised by the brick or bricklet, such as InvalidParameter, FunctionNotSupported and UnknownError will be returned. If the received response can not be interpreted as the result type T, a MalformedPacket error is raised.

§Note

If the device is configured to send no response for a result-less setter, the Error SuccessButResponseExpectedIsDisabled will be returned. This indicates, that the request was sent to the device, but no further guarantees can be made.

Implementations§

source§

impl<T: FromByteSlice> ConvertingReceiver<T>

source

pub fn new( receiver: Receiver<Result<Vec<u8>, BrickletError>>, timeout: Duration ) -> ConvertingReceiver<T>

Creates a new converting receiver which wraps the given Receiver. recv calls will time out after the given timeout.

source

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

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

§Errors

Returns an error on the following conditions:

  • There is no connection to a brick daemon.
  • The brick or bricklet returns an error.
  • The queue was disconnected or currently empty.
  • Response expected was disabled for a result-less setter. This is not an error.
source

pub fn recv(&self) -> Result<T, BrickletRecvTimeoutError>

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:

  • There is no connection to a brick daemon.
  • The brick or bricklet returns an error.
  • The queue was disconnected.
  • Response expected was disabled for a result-less setter. This is not an error.
  • Blocked longer than the configured time out.
source

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

source

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

Trait Implementations§

source§

impl<'a, T: FromByteSlice> IntoIterator for &'a ConvertingReceiver<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?
source§

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

Creates an iterator from a value. Read more
source§

impl<T: FromByteSlice> IntoIterator for ConvertingReceiver<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?
source§

fn into_iter(self) -> IntoIter<T>

Creates an iterator from a value. Read more

Auto Trait Implementations§

§

impl<T> RefUnwindSafe for ConvertingReceiver<T>
where T: RefUnwindSafe,

§

impl<T> Send for ConvertingReceiver<T>
where T: Send,

§

impl<T> !Sync for ConvertingReceiver<T>

§

impl<T> Unpin for ConvertingReceiver<T>
where T: Unpin,

§

impl<T> UnwindSafe for ConvertingReceiver<T>
where T: UnwindSafe,

Blanket Implementations§

source§

impl<T> Any for T
where T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Borrow<T> for T
where T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T, U> Into<U> for T
where U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T> Same for T

§

type Output = T

Should always be Self
source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

§

fn vzip(self) -> V