chat_app

hydro_test::local::chat_app

Function chat_app 

Source 
pub fn chat_app<'a>(
    process: &Process<'a>,
    users_stream: Stream<u32, Process<'a>, Unbounded>,
    messages: Stream<String, Process<'a>, Unbounded>,
    replay_messages: bool,
    nondet_user_arrival_broadcast: NonDet,
) -> Stream<(u32, String), Process<'a>, Unbounded, NoOrder>