pub async fn parse_step_from_stream( line: String, stream: &mut OutputStream) -> Result<Option<Vec<Step>>, Error>