Skip to content

Commit

Permalink
Merge pull request ReactiveX#349 from benjchristensen/window-operator
Browse files Browse the repository at this point in the history
Window Operator
  • Loading branch information
benjchristensen committed Sep 5, 2013
2 parents 87b76f2 + 5e0a2c0 commit bb8acc5
Show file tree
Hide file tree
Showing 8 changed files with 1,647 additions and 679 deletions.
261 changes: 237 additions & 24 deletions rxjava-core/src/main/java/rx/Observable.java

Large diffs are not rendered by default.

599 changes: 599 additions & 0 deletions rxjava-core/src/main/java/rx/operators/ChunkedOperation.java

Large diffs are not rendered by default.

783 changes: 138 additions & 645 deletions rxjava-core/src/main/java/rx/operators/OperationBuffer.java

Large diffs are not rendered by default.

663 changes: 663 additions & 0 deletions rxjava-core/src/main/java/rx/operators/OperationWindow.java

Large diffs are not rendered by default.

Original file line number Diff line number Diff line change
Expand Up @@ -15,6 +15,6 @@
*/
package rx.util;

public interface BufferClosing {
public interface Closing {
// Tagging interface for objects which can close buffers.
}
Original file line number Diff line number Diff line change
Expand Up @@ -15,13 +15,13 @@
*/
package rx.util;

public class BufferClosings {
public class Closings {

public static BufferClosing create() {
return new BufferClosing() {};
public static Closing create() {
return new Closing() {};
}

private BufferClosings() {
private Closings() {
// Prevent instantation.
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -15,6 +15,6 @@
*/
package rx.util;

public interface BufferOpening {
public interface Opening {
// Tagging interface for objects which can open buffers.
}
Original file line number Diff line number Diff line change
Expand Up @@ -15,13 +15,13 @@
*/
package rx.util;

public class BufferOpenings {
public class Openings {

public static BufferOpening create() {
return new BufferOpening() {};
public static Opening create() {
return new Opening() {};
}

private BufferOpenings() {
private Openings() {
// Prevent instantation.
}
}

0 comments on commit bb8acc5

Please sign in to comment.