Commit b1bf657 1 parent 0cd2613 commit b1bf657 Copy full SHA for b1bf657
File tree 1 file changed +0
-3
lines changed
opentelemetry-sdk/src/metrics
1 file changed +0
-3
lines changed Original file line number Diff line number Diff line change @@ -268,20 +268,17 @@ impl<RT: Runtime> PeriodicReaderWorker<RT> {
268
268
async fn process_message ( & mut self , message : Message ) -> bool {
269
269
match message {
270
270
Message :: Export => {
271
- println ! ( "Export called" ) ;
272
271
if let Err ( err) = self . collect_and_export ( ) . await {
273
272
global:: handle_error ( err)
274
273
}
275
274
}
276
275
Message :: Flush ( ch) => {
277
- println ! ( "Flush called" ) ;
278
276
let res = self . collect_and_export ( ) . await ;
279
277
if ch. send ( res) . is_err ( ) {
280
278
global:: handle_error ( MetricsError :: Other ( "flush channel closed" . into ( ) ) )
281
279
}
282
280
}
283
281
Message :: Shutdown ( ch) => {
284
- println ! ( "Shutdown called" ) ;
285
282
let res = self . collect_and_export ( ) . await ;
286
283
let _ = self . reader . exporter . shutdown ( ) ;
287
284
if ch. send ( res) . is_err ( ) {
You can’t perform that action at this time.
0 commit comments