Merge pull request ReactiveX#281 from michaeldejong/operation-buffer

Operation: buffer
rickbw · Jul 22, 2013 · 7e84c8f · 7e84c8f
2 parents ef0b52e + 89e630a
commit 7e84c8f
Show file tree

Hide file tree

Showing 6 changed files with 1,614 additions and 0 deletions.
diff --git a/rxjava-core/src/main/java/rx/Observable.java b/rxjava-core/src/main/java/rx/Observable.java
diff --git a/rxjava-core/src/main/java/rx/operators/OperationBuffer.java b/rxjava-core/src/main/java/rx/operators/OperationBuffer.java
diff --git a/rxjava-core/src/main/java/rx/util/BufferClosing.java b/rxjava-core/src/main/java/rx/util/BufferClosing.java
@@ -0,0 +1,5 @@
+package rx.util;
+
+public interface BufferClosing {
+    // Tagging interface for objects which can close buffers.
+}
diff --git a/rxjava-core/src/main/java/rx/util/BufferClosings.java b/rxjava-core/src/main/java/rx/util/BufferClosings.java
@@ -0,0 +1,12 @@
+package rx.util;
+
+public class BufferClosings {
+
+    public static BufferClosing create() {
+        return new BufferClosing() {};
+    }
+
+    private BufferClosings() {
+        // Prevent instantation.
+    }
+}
diff --git a/rxjava-core/src/main/java/rx/util/BufferOpening.java b/rxjava-core/src/main/java/rx/util/BufferOpening.java
@@ -0,0 +1,5 @@
+package rx.util;
+
+public interface BufferOpening {
+    // Tagging interface for objects which can open buffers.
+}
diff --git a/rxjava-core/src/main/java/rx/util/BufferOpenings.java b/rxjava-core/src/main/java/rx/util/BufferOpenings.java
@@ -0,0 +1,12 @@
+package rx.util;
+
+public class BufferOpenings {
+
+    public static BufferOpening create() {
+        return new BufferOpening() {};
+    }
+
+    private BufferOpenings() {
+        // Prevent instantation.
+    }
+}