Skip to main content

execute

tinyflow_framework::stream::chain_execute

Function execute 

Source 
pub async fn execute(env: StreamEnv) -> StreamResult<()>
Expand description

Run the built operator chain until Ctrl+C, task failure, or checkpoint manager exit.