Function with_membership 

pub(crate) async fn with_membership(
    services: &Services,
    pdu: PduEvent,
    user_id: &UserId,
    encrypted: bool,
) -> PduEvent

annotate_membership consume-and-return adapter for stream chains.