diff --git a/src/examples/src/main.rs b/src/examples/src/main.rs index dd1c447..e85cd07 100644 --- a/src/examples/src/main.rs +++ b/src/examples/src/main.rs @@ -67,21 +67,21 @@ async fn test_client() -> Result<(), Box> { println!("{:#?}", test); let scroller_req: SlackApiUsersListRequest = SlackApiUsersListRequest::new().with_limit(1); - let scroller_stream = scroller_req.scroller(); + let scroller = scroller_req.scroller(); let mut resp_stream: BoxStream> = - scroller_stream.to_stream(&session); + scroller.to_stream(&session); while let Some(item) = resp_stream.try_next().await? { println!("res: {:#?}", item.members); } - let collected_members: Vec = scroller_stream + let collected_members: Vec = scroller .collect_items_stream(&session, Duration::from_millis(1000)) .await?; println!("collected res: {:#?}", collected_members); - let mut items_stream = scroller_stream.to_items_stream(&session); + let mut items_stream = scroller.to_items_stream(&session); while let Some(items) = items_stream.try_next().await? { println!("res: {:#?}", items); }