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