kiroshi 0.1.0

An opinionated image diffusion server for Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25

pub use futures::SinkExt;
pub use futures::stream::{Stream, StreamExt};

use futures::Future;
use futures::channel::mpsc;
use futures::stream;

pub fn from_future<T, E, F>(
    f: impl FnOnce(mpsc::Sender<T>) -> F,
) -> impl Stream<Item = Result<T, E>>
where
    F: Future<Output = Result<(), E>>,
{
    let (sender, receiver) = mpsc::channel(1);

    stream::select(
        receiver.map(Ok),
        stream::once(f(sender)).filter_map(|result| async move {
            match result {
                Ok(()) => None,
                Err(error) => Some(Err(error)),
            }
        }),
    )
}