Module events 

Re-exports

use std::iter::once; 🔒

use axum::extract::State; 🔒

use futures::Stream; 🔒

use futures::StreamExt; 🔒

use futures::future::ok; 🔒

use futures::pin_mut; 🔒

use ruma::UserId; 🔒

use ruma::api::client::peeking::listen_to_new_events::v3::Request; 🔒

use ruma::api::client::peeking::listen_to_new_events::v3::Response; 🔒

use tokio::time::timeout_at; 🔒

use tuwunel_core::Err; 🔒

use tuwunel_core::Result; 🔒

use tuwunel_core::err; 🔒

use tuwunel_core::utils::BoolExt; 🔒

use tuwunel_core::utils::OptionExt; 🔒

use tuwunel_core::utils::future::OptionFutureExt; 🔒

use tuwunel_core::utils::stream::IterStream; 🔒

use tuwunel_core::utils::stream::ReadyExt; 🔒

use tuwunel_core::utils::stream::WidebandExt; 🔒

use tuwunel_matrix::Event; 🔒

use tuwunel_matrix::PduCount; 🔒

use tuwunel_service::Services; 🔒

use tuwunel_service::rooms::timeline::PdusIterItem; 🔒

use super::visibility_filter; 🔒

use crate::Ruma; 🔒

use crate::utils::sync_deadline; 🔒

Structs

Listen 🔒

One user’s listen on one room’s event stream.

Constants

EVENT_LIMIT 🔒

Functions

events_route 🔒

GET /_matrix/client/v3/events

listen_filter 🔒

Keeps an event the listener may see.

visible_page 🔒

The events of a window the user may see, as one page of the stream.

window_page 🔒

The page for a window of new events, or None while the window is empty.