fn drain_cobalt_events(&mut self, test_fut: &mut (impl Future + Unpin)) {
            drain_cobalt_events(
                &mut self.exec,
                &mut self.cobalt_1dot1_stream,
                &mut self.cobalt_events,
                test_fut,
            )
        }
/// Continually execute the future and respond to any incoming Cobalt request with Ok.
/// Append each metric request payload into `self.cobalt_events`.
Continually execute the future and respond to any incoming Cobalt request with Ok.
Append each metric request payload into `self.cobalt_events`.
Continually execute the future and respond to any incoming Cobalt request with Ok . Append each metric request payload into ` self . cobalt_events ` .
fn drain_cobalt_events(&mut self, test_fut: &mut (impl Future + Unpin)) {
            drain_cobalt_events(
                &mut self.exec,
                &mut self.cobalt_1dot1_stream,
                &mut self.cobalt_events,
                test_fut,
            )
        }
fn drain_cobalt_events ( & mut self , test_fut : & mut ( impl Future + Unpin ) ) { drain_cobalt_events ( & mut self . exec , & mut self . cobalt_1dot1_stream , & mut self . cobalt_events , test_fut , ) }
Continually execute the future and respond to any incoming Cobalt request with Ok.
Append each metric request payload into `self.cobalt_events`.
Continually execute the future and respond to any incoming Cobalt request with Ok . Append each metric request payload into ` self . cobalt_events ` .
&mut self
test_fut
&mut (impl Future + Unpin)
&mut self
test_fut
&mut (impl Future + Unpin)