Struct kube_runtime::reflector::ReflectHandle

pub struct ReflectHandle<K>
where
    K: Lookup + Clone + 'static,
    K::DynamicType: Eq + Hash + Clone,
{ /* private fields */ }

A handle to a shared stream reader

ReflectHandles are created by calling [subscribe()] on a Writer, or by calling clone() on an already existing ReflectHandle. Each shared stream reader should be polled independently and driven to readiness to avoid deadlocks. When the Writer’s buffer is filled, backpressure will be applied on the root stream side.

When the root stream is dropped, or it ends, all ReflectHandles subscribed to the stream will also terminate after all events yielded by the root stream have been observed. This means ReflectHandle streams can still be polled after the root stream has been dropped.

Implementations

impl<K> ReflectHandle<K>

where K: Lookup + Clone, K::DynamicType: Eq + Hash + Clone,

pub fn reader(&self) -> Store<K>

Trait Implementations

impl<K> Clone for ReflectHandle<K>

where K: Lookup + Clone + 'static, K::DynamicType: Eq + Hash + Clone,

fn clone(&self) -> Self

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<K> Stream for ReflectHandle<K>

where K: Lookup + Clone, K::DynamicType: Eq + Hash + Clone + Default,

type Item = Arc<K>

Values yielded by the stream.

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.

impl<'pin, K> Unpin for ReflectHandle<K>

where K: Lookup + Clone + 'static, K::DynamicType: Eq + Hash + Clone, __ReflectHandle<'pin, K>: Unpin,