From 689fea890c75e42af48549ce987c1b312de698b0 Mon Sep 17 00:00:00 2001 From: Tomas Mikula Date: Thu, 5 Jun 2014 15:48:46 +0200 Subject: [PATCH] Minor edits. --- reactfx/src/main/java/org/reactfx/BiEventStream.java | 1 + reactfx/src/main/java/org/reactfx/TriEventStream.java | 1 + reactfx/src/test/java/org/reactfx/DistinctStreamTest.java | 2 +- 3 files changed, 3 insertions(+), 1 deletion(-) diff --git a/reactfx/src/main/java/org/reactfx/BiEventStream.java b/reactfx/src/main/java/org/reactfx/BiEventStream.java index 37d2fce..6017592 100644 --- a/reactfx/src/main/java/org/reactfx/BiEventStream.java +++ b/reactfx/src/main/java/org/reactfx/BiEventStream.java @@ -38,6 +38,7 @@ default BiEventStream filter( return new FilterBiStream<>(this, predicate); } + @Override default BiEventStream distinct() { return new DistinctBiStream<>(this); } diff --git a/reactfx/src/main/java/org/reactfx/TriEventStream.java b/reactfx/src/main/java/org/reactfx/TriEventStream.java index 56be438..6ea6960 100644 --- a/reactfx/src/main/java/org/reactfx/TriEventStream.java +++ b/reactfx/src/main/java/org/reactfx/TriEventStream.java @@ -38,6 +38,7 @@ default TriEventStream filter( return new FilterTriStream<>(this, predicate); } + @Override default TriEventStream distinct() { return new DistinctTriStream<>(this); } diff --git a/reactfx/src/test/java/org/reactfx/DistinctStreamTest.java b/reactfx/src/test/java/org/reactfx/DistinctStreamTest.java index b6a6fa4..c834cd2 100644 --- a/reactfx/src/test/java/org/reactfx/DistinctStreamTest.java +++ b/reactfx/src/test/java/org/reactfx/DistinctStreamTest.java @@ -124,7 +124,7 @@ public void testTriStream() { checkList(Tuples.t(4L, 5L, 6L), distinctCollector); } - private void checkList(Object elem, List list) { + private void checkList(Object elem, List list) { assertEquals(Arrays.asList(elem), list); list.clear(); }