Merge pull request #1 from johnmanjiro13/continue-when-error

fix: Continue when some error occurred
johnmanjiro13 · Jan 8, 2023 · bddfeed · bddfeed
2 parents c941471 + 328532e
commit bddfeed
Showing 1 changed file with 8 additions and 2 deletions.
diff --git a/src/worker.rs b/src/worker.rs
@@ -35,11 +35,17 @@ impl Worker {
                     let mut buf = Vec::new();
                     match record.serialize(&mut Serializer::new(&mut buf)) {
                         Ok(_) => (),
-                        Err(e) => warn!("failed to serialize a message: {}", e),
+                        Err(e) => {
+                            warn!("failed to serialize a message: {}", e);
+                            continue;
+                        }
                     }
                     match self.conn.write_all(&buf).await {
                         Ok(_) => (),
-                        Err(e) => warn!("failed to send a message to the fluent server: {}", e),
+                        Err(e) => {
+                            warn!("failed to send a message to the fluent server: {}", e);
+                            continue;
+                        }
                     }
                 }
                 Err(channel::TryRecvError::Empty) => continue,