Struct yaque::ReceiverBuilder[][src]

pub struct ReceiverBuilder { /* fields omitted */ }

Implementations

impl ReceiverBuilder[src]

pub fn new() -> ReceiverBuilder[src]

pub fn save_every_nth(self, nth: Option<usize>) -> ReceiverBuilder[src]

pub fn save_every(self, duration: Option<Duration>) -> ReceiverBuilder[src]

pub fn open<P: AsRef<Path>>(self, base: P) -> Result<Receiver>[src]

Opens a queue for reading. The access will be exclusive, based on the existence of the temporary file recv.lock inside the queue folder.

Errors

This function will return an IO error if the queue is already in use for receiving, which is indicated by a lock file. Also, any other IO error encountered while opening will be sent.

Panics

This function will panic if it is not able to set up the notification handler to watch for file changes.

Trait Implementations

impl Default for ReceiverBuilder[src]

Auto Trait Implementations

Blanket Implementations

impl<T> Any for T where
    T: 'static + ?Sized
[src]

impl<T> Any for T where
    T: Any

impl<T> Borrow<T> for T where
    T: ?Sized
[src]

impl<T> BorrowMut<T> for T where
    T: ?Sized
[src]

impl<T> From<T> for T[src]

impl<T, U> Into<U> for T where
    U: From<T>, 
[src]

impl<T> Pointable for T

type Init = T

The type for initializers.

impl<T, U> TryFrom<U> for T where
    U: Into<T>, 
[src]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, 
[src]

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

The type returned in the event of a conversion error.

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