flurx 0.1.6

Create reactive asynchronous data flow
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

use std::fmt::{Display, Formatter};

pub type FutureResult<Out> = Result<Out, AlreadyDroppedScheduler>;

#[non_exhaustive]
#[derive(Debug, Eq, PartialEq, Copy, Clone, Hash, Ord, PartialOrd)]
pub struct AlreadyDroppedScheduler;

impl Display for AlreadyDroppedScheduler {
    fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result {
        f.write_str("already dropped scheduler")
    }
}

impl std::error::Error for AlreadyDroppedScheduler {}