Operation: buffer

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.
+}

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.
+    }
+}

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.
+}

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.
+    }
+}