[−][src]Struct yaque::queue::Receiver
The receiver part of the queue. This part is asynchronous and therefore needs an executor that will the poll the futures to completion.
Implementations
impl Receiver
[src]
pub fn open<P: AsRef<Path>>(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.
pub fn save(&mut self) -> Result<()>
[src]
Saves the receiver queue state. You do not need to use method in most circumstances, since it is automatically done on drop (yes, it will be called eve if your thread panics). However, you can use this function to
-
Make periodical backups. Use an external timer implementation for this.
-
Handle possible IO errors in logging the state of the queue to the disk after commit. The
drop
implementation will ignore (but log) any io errors, which may lead to data loss in an unreliable filesystem. It was implemented this way because no errors are allowed to propagate on drop and panicking will abort the program if drop is called during a panic.
pub async fn recv<'_, '_>(&'_ mut self) -> Result<RecvGuard<'_, Vec<u8>>>
[src]
Tries to retrieve an element from the queue. The returned value is a guard that will only commit state changes to the queue when dropped.
This operation is atomic. If the returned future is not polled to
completion, as, e.g., when calling select
, the operation will be
undone.
Panics
This function will panic if it has to start reading a new segment and it is not able to set up the notification handler to watch for file changes.
pub async fn recv_timeout<F, '_, '_>(
&'_ mut self,
timeout: F
) -> Result<Option<RecvGuard<'_, Vec<u8>>>> where
F: Future<Output = ()> + Unpin,
[src]
&'_ mut self,
timeout: F
) -> Result<Option<RecvGuard<'_, Vec<u8>>>> where
F: Future<Output = ()> + Unpin,
Tries to retrieve an element from the queue until a given future
finishes. If an element arrives first, he returned value is a guard
that will only commit state changes to the queue when dropped.
Otherwise, Ok(None)
is returned.
This operation is atomic. If the returned future is not polled to
completion, as, e.g., when calling select
, the operation will be
undone.
Panics
This function will panic if it has to start reading a new segment and it is not able to set up the notification handler to watch for file changes.
pub async fn recv_batch<'_, '_>(
&'_ mut self,
n: usize
) -> Result<RecvGuard<'_, Vec<Vec<u8>>>>
[src]
&'_ mut self,
n: usize
) -> Result<RecvGuard<'_, Vec<Vec<u8>>>>
Tries to remove a number of elements from the queue. The returned value is a guard that will only commit state changes to the queue when dropped.
Note
This operation is atomic in an asynchronous context. This means that you will not lose the elements if you do not await this function to completion.
Panics
This function will panic if it has to start reading a new segment and it is not able to set up the notification handler to watch for file changes.
pub async fn recv_batch_timeout<F, '_, '_>(
&'_ mut self,
n: usize,
timeout: F
) -> Result<RecvGuard<'_, Vec<Vec<u8>>>> where
F: Future<Output = ()> + Unpin,
[src]
&'_ mut self,
n: usize,
timeout: F
) -> Result<RecvGuard<'_, Vec<Vec<u8>>>> where
F: Future<Output = ()> + Unpin,
Tries to remove a number of elements from the queue until a given future
finished. The values taken from the queue will be the values that were
available durng the whole execution of the future and thus less than n
elements might be returned. The returned items are wrapped in a guard
that will only commit state changes to the queue when dropped.
Note
This operation is atomic in an asynchronous context. This means that you will not lose the elements if you do not await this function to completion.
Panics
This function will panic if it has to start reading a new segment and it is not able to set up the notification handler to watch for file changes.
pub async fn recv_until<P, Fut, '_, '_>(
&'_ mut self,
predicate: P
) -> Result<RecvGuard<'_, Vec<Vec<u8>>>> where
P: FnMut(Option<&[u8]>) -> Fut,
Fut: Future<Output = bool>,
[src]
&'_ mut self,
predicate: P
) -> Result<RecvGuard<'_, Vec<Vec<u8>>>> where
P: FnMut(Option<&[u8]>) -> Fut,
Fut: Future<Output = bool>,
Takes a number of elements from the queue until a certain asynchronous condition is met. Use this function if you want to have fine-grained control over the contents of the receive guard.
Note that the predicate function will receive a None
as the first
element. This allows you to return early and leave the queue intact.
The returned value is a guard that will only commit state changes to
the queue when dropped.
Note
This operation is atomic in an asynchronous context. This means that you will not lose the elements if you do not await this function to completion.
Example
Receive until an empty element is received:
let recv_guard = receiver.recv_until(|element| async { element.is_empty() });
Panics
This function will panic if it has to start reading a new segment and it is not able to set up the notification handler to watch for file changes.
Trait Implementations
Auto Trait Implementations
impl RefUnwindSafe for Receiver
[src]
impl Send for Receiver
[src]
impl Sync for Receiver
[src]
impl Unpin for Receiver
[src]
impl UnwindSafe for Receiver
[src]
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Any for T where
T: Any,
T: Any,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> Pointable for T
pub const ALIGN: usize
type Init = T
The type for initializers.
pub unsafe fn init(init: <T as Pointable>::Init) -> usize
pub unsafe fn deref<'a>(ptr: usize) -> &'a T
pub unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T
pub unsafe fn drop(ptr: usize)
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,