Update subscription.md
This commit is contained in:
parent
40e92f46f1
commit
05b86e3f3c
|
@ -11,12 +11,13 @@ struct Subscription;
|
|||
|
||||
#[Subscription]
|
||||
impl Subscription {
|
||||
async fn integers(&self, #[graphql(default = "1")] step: i32) -> impl Stream<Item = i32> {
|
||||
async fn integers(&self, #[graphql(default = 1)] step: i32) -> impl Stream<Item = i32> {
|
||||
let mut value = 0;
|
||||
tokio::time::interval(Duration::from_secs(1)).map(move |_| {
|
||||
value += step;
|
||||
value
|
||||
})
|
||||
tokio_stream::wrappers::IntervalStream::new(tokio::time::interval(Duration::from_secs(1)))
|
||||
.map(move |_| {
|
||||
value += step;
|
||||
value
|
||||
})
|
||||
}
|
||||
}
|
||||
```
|
||||
|
|
|
@ -11,12 +11,13 @@ struct Subscription;
|
|||
|
||||
#[Subscription]
|
||||
impl Subscription {
|
||||
async fn integers(&self, #[graphql(default = "1")] step: i32) -> impl Stream<Item = i32> {
|
||||
async fn integers(&self, #[graphql(default = 1)] step: i32) -> impl Stream<Item = i32> {
|
||||
let mut value = 0;
|
||||
tokio::time::interval(Duration::from_secs(1)).map(move |_| {
|
||||
value += step;
|
||||
value
|
||||
})
|
||||
tokio_stream::wrappers::IntervalStream::new(tokio::time::interval(Duration::from_secs(1)))
|
||||
.map(move |_| {
|
||||
value += step;
|
||||
value
|
||||
})
|
||||
}
|
||||
}
|
||||
```
|
||||
|
|
Loading…
Reference in New Issue