pub(crate) async fn run(stream: Io1HarnessRequestStream) -> Result<(), Error>