Skip to main content

maelstrom_client_source

hydro_lang::deploy::maelstrom::deploy_runtime_maelstrom

Function maelstrom_client_source 

Source 
pub fn maelstrom_client_source(
    meta: &MaelstromMeta,
) -> impl Stream<Item = (String, Value)> + Unpin
Available on crate feature deploy and (crate features maelstrom or maelstrom_runtime) only.
Expand description

Creates a stream of client messages from Maelstrom stdin. Returns tuples of (client_id, message_body) where client_id is the source client and message_body is the JSON value of the message body.

This function is meant to be used with source_stream on a Cluster location.