in src/reporter/grpc.rs [256:262]
fn report(&self, item: CollectItem) {
if !self.state.is_closing() {
if let Err(e) = self.producer.produce(item) {
(self.err_handle)("report collect item failed", &*e);
}
}
}