Skip to content

Commit 26696d8

Browse files
author
Matt Laux
committed
1.x: TestSubscriber::assertValuesAndClear should reset valueCount
1 parent 1dd023f commit 26696d8

File tree

3 files changed

+13
-1
lines changed

3 files changed

+13
-1
lines changed

src/main/java/rx/observers/TestSubscriber.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -703,5 +703,6 @@ public final void assertValuesAndClear(T expectedFirstValue, T... expectedRestVa
703703
assertItem(expectedRestValues[i], i + 1);
704704
}
705705
values.clear();
706+
valueCount = 0;
706707
}
707708
}

src/test/java/rx/observers/AssertableSubscriberTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -151,7 +151,7 @@ public void testSingle() {
151151
assertEquals(Thread.currentThread().getName(), ts.getLastSeenThread().getName());
152152
assertTrue(ts.getOnErrorEvents().isEmpty());
153153
assertTrue(ts.getOnNextEvents().isEmpty());
154-
assertEquals(1, ts.getValueCount());
154+
assertEquals(0, ts.getValueCount());
155155
}
156156

157157
@Test

src/test/java/rx/observers/TestSubscriberTest.java

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -815,4 +815,15 @@ public void assertAndConsume() {
815815

816816
ts.assertNoValues();
817817
}
818+
819+
@Test
820+
public void assertAndClearResetsValueCount() {
821+
TestSubscriber<Integer> ts = TestSubscriber.create();
822+
823+
ts.onNext(1);
824+
ts.assertValuesAndClear(1);
825+
826+
ts.assertNoValues();
827+
Assert.assertEquals(0, ts.getValueCount());
828+
}
818829
}

0 commit comments

Comments
 (0)