pub async fn execute( ctx: &Context, request: Request, ) -> Result<Pin<Box<dyn Stream<Item = Result<ResponseItem, Error>> + Send>>, Error>