Struct timely::dataflow::operators::CapabilityRef
source · pub struct CapabilityRef<'cap, T: Timestamp + 'cap> { /* private fields */ }
Expand description
An unowned capability, which can be used but not retained.
The capability reference supplies a retain(self)
method which consumes the reference
and turns it into an owned capability
Implementations
sourceimpl<'cap, T: Timestamp + 'cap> CapabilityRef<'cap, T>
impl<'cap, T: Timestamp + 'cap> CapabilityRef<'cap, T>
sourcepub fn delayed(&self, new_time: &T) -> Capability<T>
pub fn delayed(&self, new_time: &T) -> Capability<T>
Makes a new capability for a timestamp new_time
greater or equal to the timestamp of
the source capability (self
).
This method panics if self.time
is not less or equal to new_time
.
sourcepub fn delayed_for_output(
&self,
new_time: &T,
output_port: usize
) -> Capability<T>
pub fn delayed_for_output(
&self,
new_time: &T,
output_port: usize
) -> Capability<T>
Delays capability for a specific output port.
sourcepub fn retain(self) -> Capability<T>
pub fn retain(self) -> Capability<T>
Transform to an owned capability.
This method produces an owned capability which must be dropped to release the capability. Users should take care that these capabilities are only stored for as long as they are required, as failing to drop them may result in livelock.
sourcepub fn retain_for_output(self, output_port: usize) -> Capability<T>
pub fn retain_for_output(self, output_port: usize) -> Capability<T>
Transforms to an owned capability for a specific output port.
Trait Implementations
sourceimpl<'cap, T: Timestamp> Debug for CapabilityRef<'cap, T>
impl<'cap, T: Timestamp> Debug for CapabilityRef<'cap, T>
Auto Trait Implementations
impl<'cap, T> !RefUnwindSafe for CapabilityRef<'cap, T>
impl<'cap, T> !Send for CapabilityRef<'cap, T>
impl<'cap, T> !Sync for CapabilityRef<'cap, T>
impl<'cap, T> Unpin for CapabilityRef<'cap, T>
impl<'cap, T> !UnwindSafe for CapabilityRef<'cap, T>
Blanket Implementations
sourceimpl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more