From d50dc0b0973327479022931b0680786eaa46847e Mon Sep 17 00:00:00 2001
From: Robert Smallshire <robert@smallshire.org.uk>
Date: Thu, 23 Oct 2014 11:37:07 +0200
Subject: [PATCH] Adds a function for batching iterable series.

---
 util.py | 15 +++++++++++++++
 1 file changed, 15 insertions(+)

diff --git a/util.py b/util.py
index ac74425..5fe99ee 100644
--- a/util.py
+++ b/util.py
@@ -18,6 +18,21 @@ def pairwise(iterable):
     next(b, None)
     return izip(a, b)
 
+def batched(iterable, batch_size):
+    """
+    """
+    pending = []
+    batch = pending
+
+    for item in iterable:
+        pending.append(item)
+        if len(pending) == batch_size:
+            batch = pending
+            pending = []
+            yield batch
+
+    if len(pending) > 0:
+        yield batch
 
 def contains_duplicates(sorted_iterable):
     """Determine in an iterable series contains duplicates.