System-End/slack-morphism-rust
1
0
Fork 0
mirror of https://github.com/System-End/slack-morphism-rust.git synced 2026-04-19 22:05:15 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Example renames

Browse source
This commit is contained in:
Abdulla Abdurakhmanov 2020-06-20 00:13:35 +03:00
parent 97b0d1de68
commit b7329406ef
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
src/examples/src/main.rs
View file

@ -67,21 +67,21 @@ async fn test_client() -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
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<ClientResult<SlackApiUsersListResponse>> =
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<SlackUser> = scroller_stream
let collected_members: Vec<SlackUser> = 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);
}