pub trait Stream<Request> {
type Response;
type Function: Future<Output = Self::Response>;
// Required method
fn next(&self, request: Request) -> Self::Function;
}
pub trait Stream<Request> {
type Response;
type Function: Future<Output = Self::Response>;
// Required method
fn next(&self, request: Request) -> Self::Function;
}