@@ -38,7 +38,7 @@ public class BackpressureTests {
3838
3939 @ Test
4040 public void testObserveOn () {
41- int NUM = (int ) (( int ) RxRingBuffer .SIZE * 2.1 );
41+ int NUM = (int ) (RxRingBuffer .SIZE * 2.1 );
4242 AtomicInteger c = new AtomicInteger ();
4343 TestSubscriber <Integer > ts = new TestSubscriber <Integer >();
4444 incrementingIntegers (c ).observeOn (Schedulers .computation ()).take (NUM ).subscribe (ts );
@@ -51,7 +51,7 @@ public void testObserveOn() {
5151
5252 @ Test
5353 public void testObserveOnWithSlowConsumer () {
54- int NUM = (int ) (( int ) RxRingBuffer .SIZE * 0.2 );
54+ int NUM = (int ) (RxRingBuffer .SIZE * 0.2 );
5555 AtomicInteger c = new AtomicInteger ();
5656 TestSubscriber <Integer > ts = new TestSubscriber <Integer >();
5757 incrementingIntegers (c ).observeOn (Schedulers .computation ()).map (new Func1 <Integer , Integer >() {
@@ -76,7 +76,7 @@ public Integer call(Integer i) {
7676
7777 @ Test
7878 public void testMergeSync () {
79- int NUM = (int ) (( int ) RxRingBuffer .SIZE * 4.1 );
79+ int NUM = (int ) (RxRingBuffer .SIZE * 4.1 );
8080 AtomicInteger c1 = new AtomicInteger ();
8181 AtomicInteger c2 = new AtomicInteger ();
8282 TestSubscriber <Integer > ts = new TestSubscriber <Integer >();
@@ -97,7 +97,7 @@ public void testMergeSync() {
9797
9898 @ Test
9999 public void testMergeAsync () {
100- int NUM = (int ) (( int ) RxRingBuffer .SIZE * 4.1 );
100+ int NUM = (int ) (RxRingBuffer .SIZE * 4.1 );
101101 AtomicInteger c1 = new AtomicInteger ();
102102 AtomicInteger c2 = new AtomicInteger ();
103103 TestSubscriber <Integer > ts = new TestSubscriber <Integer >();
@@ -119,7 +119,7 @@ public void testMergeAsync() {
119119
120120 @ Test
121121 public void testMergeAsyncThenObserveOn () {
122- int NUM = (int ) (( int ) RxRingBuffer .SIZE * 4.1 );
122+ int NUM = (int ) (RxRingBuffer .SIZE * 4.1 );
123123 AtomicInteger c1 = new AtomicInteger ();
124124 AtomicInteger c2 = new AtomicInteger ();
125125 TestSubscriber <Integer > ts = new TestSubscriber <Integer >();
@@ -141,7 +141,7 @@ public void testMergeAsyncThenObserveOn() {
141141
142142 @ Test
143143 public void testFlatMapSync () {
144- int NUM = (int ) (( int ) RxRingBuffer .SIZE * 2.1 );
144+ int NUM = (int ) (RxRingBuffer .SIZE * 2.1 );
145145 AtomicInteger c = new AtomicInteger ();
146146 TestSubscriber <Integer > ts = new TestSubscriber <Integer >();
147147 incrementingIntegers (c ).flatMap (new Func1 <Integer , Observable <Integer >>() {
@@ -162,7 +162,7 @@ public Observable<Integer> call(Integer i) {
162162
163163 @ Test
164164 public void testFlatMapAsync () {
165- int NUM = (int ) (( int ) RxRingBuffer .SIZE * 2.1 );
165+ int NUM = (int ) (RxRingBuffer .SIZE * 2.1 );
166166 AtomicInteger c = new AtomicInteger ();
167167 TestSubscriber <Integer > ts = new TestSubscriber <Integer >();
168168 incrementingIntegers (c ).subscribeOn (Schedulers .computation ()).flatMap (new Func1 <Integer , Observable <Integer >>() {
@@ -185,7 +185,7 @@ public Observable<Integer> call(Integer i) {
185185
186186 @ Test
187187 public void testZipSync () {
188- int NUM = (int ) (( int ) RxRingBuffer .SIZE * 4.1 );
188+ int NUM = (int ) (RxRingBuffer .SIZE * 4.1 );
189189 AtomicInteger c1 = new AtomicInteger ();
190190 AtomicInteger c2 = new AtomicInteger ();
191191 TestSubscriber <Integer > ts = new TestSubscriber <Integer >();
@@ -212,7 +212,7 @@ public Integer call(Integer t1, Integer t2) {
212212
213213 @ Test
214214 public void testZipAsync () {
215- int NUM = (int ) (( int ) RxRingBuffer .SIZE * 2.1 );
215+ int NUM = (int ) (RxRingBuffer .SIZE * 2.1 );
216216 AtomicInteger c1 = new AtomicInteger ();
217217 AtomicInteger c2 = new AtomicInteger ();
218218 TestSubscriber <Integer > ts = new TestSubscriber <Integer >();
@@ -241,7 +241,7 @@ public Integer call(Integer t1, Integer t2) {
241241 public void testSubscribeOnScheduling () {
242242 // in a loop for repeating the concurrency in this to increase chance of failure
243243 for (int i = 0 ; i < 100 ; i ++) {
244- int NUM = (int ) (( int ) RxRingBuffer .SIZE * 2.1 );
244+ int NUM = (int ) (RxRingBuffer .SIZE * 2.1 );
245245 AtomicInteger c = new AtomicInteger ();
246246 ConcurrentLinkedQueue <Thread > threads = new ConcurrentLinkedQueue <Thread >();
247247 TestSubscriber <Integer > ts = new TestSubscriber <Integer >();
@@ -271,7 +271,7 @@ public void testSubscribeOnScheduling() {
271271
272272 @ Test
273273 public void testTakeFilterSkipChainAsync () {
274- int NUM = (int ) (( int ) RxRingBuffer .SIZE * 2.1 );
274+ int NUM = (int ) (RxRingBuffer .SIZE * 2.1 );
275275 AtomicInteger c = new AtomicInteger ();
276276 TestSubscriber <Integer > ts = new TestSubscriber <Integer >();
277277 incrementingIntegers (c ).observeOn (Schedulers .computation ())
@@ -411,7 +411,7 @@ public void testFirehoseFailsAsExpected() {
411411
412412 @ Test (timeout = 2000 )
413413 public void testOnBackpressureDrop () {
414- int NUM = (int ) (( int ) RxRingBuffer .SIZE * 1.1 ); // > 1 so that take doesn't prevent buffer overflow
414+ int NUM = (int ) (RxRingBuffer .SIZE * 1.1 ); // > 1 so that take doesn't prevent buffer overflow
415415 AtomicInteger c = new AtomicInteger ();
416416 TestSubscriber <Integer > ts = new TestSubscriber <Integer >();
417417 firehose (c ).onBackpressureDrop ().observeOn (Schedulers .computation ()).map (SLOW_PASS_THRU ).take (NUM ).subscribe (ts );
@@ -425,7 +425,7 @@ public void testOnBackpressureDrop() {
425425
426426 @ Test (timeout = 2000 )
427427 public void testOnBackpressureBuffer () {
428- int NUM = (int ) (( int ) RxRingBuffer .SIZE * 1.1 ); // > 1 so that take doesn't prevent buffer overflow
428+ int NUM = (int ) (RxRingBuffer .SIZE * 1.1 ); // > 1 so that take doesn't prevent buffer overflow
429429 AtomicInteger c = new AtomicInteger ();
430430 TestSubscriber <Integer > ts = new TestSubscriber <Integer >();
431431 firehose (c ).takeWhile (new Func1 <Integer , Boolean >() {
0 commit comments