Add push_many which optimises adding multiple events (#26)

client/src/lib.rs

@@ -144,7 +144,7 @@ impl<R: Runtime + Send + 'static> ClientBuilder<R> {
 }
 
 impl<R: Runtime + Send + 'static> Client<R> {
-    pub fn push_event(&mut self, event: Event) {
+    pub fn push(&mut self, event: Event) {
         let mut guard = self.inner.try_lock().unwrap();
         let idempotency_key = guard.runtime.rng();
         guard.events.push(IdempotentEvent {
@@ -158,6 +158,22 @@ impl<R: Runtime + Send + 'static> Client<R> {
         self.process_events(guard, true);
     }
 
+    pub fn push_many(&mut self, events: impl Iterator<Item = Event>) {
+        let mut guard = self.inner.try_lock().unwrap();
+        for event in events {
+            let idempotency_key = guard.runtime.rng();
+            guard.events.push(IdempotentEvent {
+                idempotency_key,
+                name: event.name,
+                timestamp: event.timestamp,
+                user: event.user,
+                source: event.source,
+                payload: event.payload,
+            });
+        }
+        self.process_events(guard, true);
+    }
+
     pub fn flush_batch(&self) {
         let guard = self.inner.try_lock().unwrap();
         self.flush_batch_within_lock(guard);

client/src/tests.rs

@@ -16,7 +16,7 @@ fn batch_flushed_when_max_batch_size_reached(flush_synchronously: bool) {
 
     for i in 0..10 {
         for _ in 0..5 {
-            client.push_event(Event {
+            client.push(Event {
                 name: i.to_string(),
                 timestamp: 0,
                 user: None,
@@ -41,7 +41,7 @@ fn batch_flushed_when_flush_delay_reached(flush_synchronously: bool) {
 
     for i in 0..10 {
         for _ in 0..5 {
-            client.push_event(Event {
+            client.push(Event {
                 name: i.to_string(),
                 timestamp: 0,
                 user: None,