in src/filtered_log_processor.rs [58:66]
fn emit(&self, data: &mut LogData) {
let result = self
.message_sender
.try_send(BatchMessage::ExportLog(data.clone()));
if let Err(err) = result {
global::handle_error(LogError::Other(err.into()));
}
}