Updated book for master ***NO_CI***
This commit is contained in:
parent
7d91c0d59c
commit
a519a237e0
4 changed files with 6 additions and 6 deletions
|
@ -181,7 +181,7 @@ type StringStream = Pin<Box<dyn Stream<Item = Result<String, FieldEr
|
||||||
#[graphql_subscription(context = Database)]
|
#[graphql_subscription(context = Database)]
|
||||||
impl Subscription {
|
impl Subscription {
|
||||||
async fn hello_world() -> StringStream {
|
async fn hello_world() -> StringStream {
|
||||||
let stream = tokio::stream::iter(vec![
|
let stream = futures::stream::iter(vec![
|
||||||
Ok(String::from("Hello")),
|
Ok(String::from("Hello")),
|
||||||
Ok(String::from("World!"))
|
Ok(String::from("World!"))
|
||||||
]);
|
]);
|
||||||
|
@ -244,7 +244,7 @@ where [<code>Connection</code>][Connection] is a <code>Stream</code> of values r
|
||||||
# impl Subscription {
|
# impl Subscription {
|
||||||
# async fn hello_world() -> StringStream {
|
# async fn hello_world() -> StringStream {
|
||||||
# let stream =
|
# let stream =
|
||||||
# tokio::stream::iter(vec![Ok(String::from("Hello")), Ok(String::from("World!"))]);
|
# futures::stream::iter(vec![Ok(String::from("Hello")), Ok(String::from("World!"))]);
|
||||||
# Box::pin(stream)
|
# Box::pin(stream)
|
||||||
# }
|
# }
|
||||||
# }
|
# }
|
||||||
|
|
|
@ -3089,7 +3089,7 @@ type StringStream = Pin<Box<dyn Stream<Item = Result<String, FieldEr
|
||||||
#[graphql_subscription(context = Database)]
|
#[graphql_subscription(context = Database)]
|
||||||
impl Subscription {
|
impl Subscription {
|
||||||
async fn hello_world() -> StringStream {
|
async fn hello_world() -> StringStream {
|
||||||
let stream = tokio::stream::iter(vec![
|
let stream = futures::stream::iter(vec![
|
||||||
Ok(String::from("Hello")),
|
Ok(String::from("Hello")),
|
||||||
Ok(String::from("World!"))
|
Ok(String::from("World!"))
|
||||||
]);
|
]);
|
||||||
|
@ -3152,7 +3152,7 @@ where [<code>Connection</code>][Connection] is a <code>Stream</code> of values r
|
||||||
# impl Subscription {
|
# impl Subscription {
|
||||||
# async fn hello_world() -> StringStream {
|
# async fn hello_world() -> StringStream {
|
||||||
# let stream =
|
# let stream =
|
||||||
# tokio::stream::iter(vec![Ok(String::from("Hello")), Ok(String::from("World!"))]);
|
# futures::stream::iter(vec![Ok(String::from("Hello")), Ok(String::from("World!"))]);
|
||||||
# Box::pin(stream)
|
# Box::pin(stream)
|
||||||
# }
|
# }
|
||||||
# }
|
# }
|
||||||
|
|
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
Loading…
Reference in a new issue