Skip to main content

broadcast_server

hydro_test::maelstrom::broadcast

Function broadcast_server 

Source 
pub fn broadcast_server<'a, C: 'a>(
    cluster: &Cluster<'a, C>,
    input: KeyedStream<String, Request, Cluster<'a, C>>,
) -> KeyedStream<String, Value, Cluster<'a, C>, Unbounded, NoOrder>