Skip to main content

handle_pdus

Function handle_pdus 

Source
async fn handle_pdus(
    services: &Services,
    client: &IpAddr,
    origin: &ServerName,
    txn_id: &TransactionId,
    started: Instant,
    pdus: impl Stream<Item = (usize, (OwnedRoomId, OwnedEventId, CanonicalJsonObject))> + Send,
) -> Result<BTreeMap<OwnedEventId, Result>>