flowly_service/stub.rs
1use std::marker::PhantomData;
2
3use futures::Stream;
4
5use crate::{Context, Service};
6
7#[inline]
8pub fn stub<O>() -> Stub<O> {
9 Stub(PhantomData)
10}
11
12#[derive(Debug, Clone, Copy)]
13pub struct Stub<O>(PhantomData<O>);
14
15impl<I: Send, O: Send> Service<I> for Stub<O> {
16 type Out = O;
17
18 fn handle(&mut self, _: I, _cx: &Context) -> impl Stream<Item = Self::Out> + Send {
19 futures::stream::empty()
20 }
21}