mirror/matrix-rust-sdk
1
0
Fork 0
mirror of https://github.com/matrix-org/matrix-rust-sdk.git synced 2026-05-06 15:04:11 -04:00
Code Issues Packages Projects Releases Wiki Activity

Fix example for Room::Common::timeline()

Browse Source
This commit is contained in:
Julian Sparber
2022-02-22 12:51:44 +01:00
parent d7592cce29
commit 84c46affa3
1 changed files with 22 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

35
crates/matrix-sdk/src/room/common.rs
View File

@@ -231,28 +231,37 @@ impl Common {
/// # room_id,
/// # };
/// # use url::Url;
/// # use futures::StreamExt;
/// # use futures_util::pin_mut;
///
/// # use futures::executor::block_on;
/// # block_on(async {
/// # let homeserver = Url::parse("http://example.com")?;
///
/// let mut client = Client::new(homeserver).await?;
/// let room = client
/// .get_joined_room(room_id!("!roomid:example.com"))?;
/// let (backward_stream, forward_stream) = room.timeline().await?;
/// tokio::spawn(async move {
/// while let Some(item) = backward_stream.next() {
/// match item {
/// Ok(event) => println!("{:?}", event),
/// Err(_) => prinln!("Some error occurred!"),
/// }
/// }
/// });
///
/// while let Some(event) = forward_stream.next().await {
/// println!("{:?}", event);
/// if let Some(room) = client.get_joined_room(room_id!("!roomid:example.com")) {
/// let (forward_stream, backward_stream) = room.timeline().await?;
///
/// tokio::spawn(async move {
/// pin_mut!(backward_stream);
///
/// while let Some(item) = backward_stream.next().await {
/// match item {
/// Ok(event) => println!("{:?}", event),
/// Err(_) => println!("Some error occurred!"),
/// }
/// }
/// });
///
/// pin_mut!(forward_stream);
///
/// while let Some(event) = forward_stream.next().await {
/// println!("{:?}", event);
/// }
/// }
///
/// # Result::<_, matrix_sdk::Error>::Ok(())
/// # });
/// ```
pub async fn timeline(