pub trait AsyncEngineStream<Resp: Data>: Stream<Item = Resp> + AsyncEngineContextProvider + Send + Sync { }