Method emit_streaming_notices

src/environmentd/src/http/sql.rs:1138–1140

(&mut self, notices: Vec<AdapterNotice>)

    }

    async fn emit_streaming_notices(&mut self, notices: Vec<AdapterNotice>) -> Result<(), Error> {
        forward_notices(self, notices).await
    }
}

async fn await_rows<S, F, R>(sender: &mut S, client: &mut SessionClient, f: F) -> Result<R, Error>