We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent d52fec7 commit 26c38c4Copy full SHA for 26c38c4
opentelemetry-sdk/src/logs/log_processor.rs
@@ -404,13 +404,10 @@ impl BatchLogProcessor {
404
let mut logs = Vec::with_capacity(config.max_export_batch_size);
405
406
loop {
407
- let remaining_time_option = config
+ let remaining_time = config
408
.scheduled_delay
409
- .checked_sub(last_export_time.elapsed());
410
- let remaining_time = match remaining_time_option {
411
- Some(remaining_time) => remaining_time,
412
- None => config.scheduled_delay,
413
- };
+ .checked_sub(last_export_time.elapsed())
+ .unwrap_or(config.scheduled_delay);
414
415
match message_receiver.recv_timeout(remaining_time) {
416
Ok(BatchMessage::ExportLog(log)) => {
0 commit comments