Struct rxrust::ops::complete_status::CompleteStatus

pub struct CompleteStatus { /* private fields */ }

Implementations

impl CompleteStatus

pub fn is_closed(&self) -> bool

return true if the observable completed or emit an error.

pub fn is_completed(&self) -> bool

return true if the observable completed.

pub fn error_occur(&self) -> bool

return true if the observable emit an error.

pub fn wait_for_end(this: Arc<Self>)

Wait until the observable complete or an error occur.

Trait Implementations

impl Default for CompleteStatus

fn default() -> CompleteStatus

Returns the “default value” for a type.