We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent f410739 commit 5ee1e14Copy full SHA for 5ee1e14
src/test/java/rx/BackpressureTests.java
@@ -549,14 +549,16 @@ public void call(final Subscriber<? super Integer> s) {
549
}
550
551
final static Func1<Integer, Integer> SLOW_PASS_THRU = new Func1<Integer, Integer>() {
552
-
+ volatile int sink;
553
@Override
554
public Integer call(Integer t1) {
555
// be slow ... but faster than Thread.sleep(1)
556
String t = "";
557
+ int s = sink;
558
for (int i = 1000; i >= 0; i--) {
- t = String.valueOf(i + t.hashCode());
559
+ t = String.valueOf(i + t.hashCode() + s);
560
561
+ sink = t.hashCode();
562
return t1;
563
564
0 commit comments