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

Operation: buffer

Author: benjchristensen

rxjava-core/src/main/java/rx/Observable.java

@@ -0,0 +1,5 @@
+package rx.util;
+
+public interface BufferClosing {
+    // Tagging interface for objects which can close buffers.
+}

rxjava-core/src/main/java/rx/operators/OperationBuffer.java

@@ -0,0 +1,12 @@
+package rx.util;
+
+public class BufferClosings {
+
+    public static BufferClosing create() {
+        return new BufferClosing() {};
+    }
+
+    private BufferClosings() {
+        // Prevent instantation.
+    }
+}

rxjava-core/src/main/java/rx/util/BufferClosing.java

@@ -0,0 +1,5 @@
+package rx.util;
+
+public interface BufferOpening {
+    // Tagging interface for objects which can open buffers.
+}

rxjava-core/src/main/java/rx/util/BufferClosings.java

@@ -0,0 +1,12 @@
+package rx.util;
+
+public class BufferOpenings {
+
+    public static BufferOpening create() {
+        return new BufferOpening() {};
+    }
+
+    private BufferOpenings() {
+        // Prevent instantation.
+    }
+}