3b7ed74d11
- examples to fix still
- error_extensions.md ResultExt example does not compile!
- trait ErrorExtensions is not implemented for ParseIntError
- dataloader
- requires sqlx to work. So we either "stub" it OR we rewrite them simpler to use a simple "faux" db library
1007 B
1007 B
订阅
订阅根对象和其它根对象定义稍有不同，它的Resolver函数总是返回一个 Stream 或者Result<Stream>，而字段参数通常作为数据的筛选条件。
下面的例子订阅一个整数流，它每秒产生一个整数，参数step指定了整数的步长，默认为1。
# extern crate async_graphql;
# use std::time::Duration;
# use async_graphql::futures_util::stream::Stream;
# use async_graphql::futures_util::StreamExt;
# extern crate tokio_stream;
# extern crate tokio;
use async_graphql::*;
struct Subscription;
#[Subscription]
impl Subscription {
async fn integers(&self, #[graphql(default = 1)] step: i32) -> impl Stream<Item = i32> {
let mut value = 0;
tokio_stream::wrappers::IntervalStream::new(tokio::time::interval(Duration::from_secs(1)))
.map(move |_| {
value += step;
value
})
}
}