[][src]Struct artemis::Observable

pub struct Observable<T, M: Exchange> { /* fields omitted */ }

An observable result. This implements Stream and unsubscribes on drop. It will receive early (partial or stale) results, as well as refreshing when the query is rerun after being invalidated by mutations.

Methods

impl<T: Clone, M: Exchange> Observable<T, M>[src]

pub fn rerun(&self)[src]

Manually cause the client to rerun this query. Note this doesn't invalidate any caching, so if the query is in the cache it will simply be re-read

Trait Implementations

impl<T, M: Exchange> Drop for Observable<T, M>[src]

impl<T, M: Exchange> Stream for Observable<T, M> where
    T: 'static + Unpin + Clone
[src]

type Item = T

Values yielded by the stream.

Auto Trait Implementations

impl<T, M> !RefUnwindSafe for Observable<T, M>

impl<T, M> Send for Observable<T, M> where
    T: Send

impl<T, M> Sync for Observable<T, M> where
    T: Sync

impl<T, M> Unpin for Observable<T, M> where
    T: Unpin

impl<T, M> !UnwindSafe for Observable<T, M>

Blanket Implementations

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

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> StreamExt for T where
    T: Stream + ?Sized
[src]

impl<St> StreamExt for St where
    St: Stream + ?Sized
[src]

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<S, T, E> TryStream for S where
    S: Stream<Item = Result<T, E>> + ?Sized
[src]

type Ok = T

The type of successful values yielded by this future

type Error = E

The type of failures yielded by this future

impl<S> TryStreamExt for S where
    S: TryStream + ?Sized
[src]