Struct ObservableFuture 

pub struct ObservableFuture<'or, T, OE>
where
    OE: Observable<'or, T, Infallible>,
{ /* private fields */ }

A Future of the first item of an Observable that cannot fail.

It resolves with Some(item) on the first item, stopping the source right there, and with None when the source completes without one. This is ObservableTryFuture without the error it can never carry; see there for how it subscribes and when it releases the source.

Examples

#[tokio::main]
async fn main() {
    use rx_rust::{
        observable::ObservableExt,
        operators::creating::{empty::Empty, from_iter::FromIter},
    };

    let first = FromIter::new([10, 20, 30]).into_future().await;
    assert_eq!(first, Some(10));

    let none = Empty.with_item_type::<i32>().into_future().await;
    assert_eq!(none, None);
}

Implementations

impl<'or, T, OE> ObservableFuture<'or, T, OE>

where OE: Observable<'or, T, Infallible>,

pub fn new(source: OE) -> Self

Trait Implementations

impl<'or, T, OE> Debug for ObservableFuture<'or, T, OE>

where OE: Observable<'or, T, Infallible>, ObservableTryFuture<'or, T, Infallible, OE>: Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'or, T, OE> Future for ObservableFuture<'or, T, OE>

where T: MaybeSend + 'or, OE: Observable<'or, T, Infallible>,

type Output = Option<T>

The type of value produced on completion.

fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output>

Attempts to resolve the future to a final value, registering the current task for wakeup if the value is not yet available.

impl<'or, T, OE> Unpin for ObservableFuture<'or, T, OE>

where OE: Observable<'or, T, Infallible>,