Skip to content

Commit fea2433

Browse files
committed
Add generics
1 parent 9b5aefd commit fea2433

File tree

1 file changed

+8
-8
lines changed

1 file changed

+8
-8
lines changed

rxjava-core/src/test/java/rx/internal/util/IndexedRingBufferTest.java

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -211,13 +211,13 @@ public void testForEachAcrossSections() {
211211
buffer.add(i);
212212
}
213213

214-
final ArrayList<String> list = new ArrayList<String>();
214+
final ArrayList<Integer> list = new ArrayList<Integer>();
215215
int nextIndex = buffer.forEach(accumulate(list), 5000);
216216
assertEquals(10000, list.size());
217-
assertEquals(5000, list.get(0));
218-
assertEquals(9999, list.get(4999));
219-
assertEquals(0, list.get(5000));
220-
assertEquals(4999, list.get(9999));
217+
assertEquals(Integer.valueOf(5000), list.get(0));
218+
assertEquals(Integer.valueOf(9999), list.get(4999));
219+
assertEquals(Integer.valueOf(0), list.get(5000));
220+
assertEquals(Integer.valueOf(4999), list.get(9999));
221221
assertEquals(5000, nextIndex);
222222
}
223223

@@ -364,11 +364,11 @@ public void call() {
364364
assertEquals(0, exceptions.size());
365365
}
366366

367-
private Func1<Object, Boolean> accumulate(final ArrayList list) {
368-
return new Func1<Object, Boolean>() {
367+
private <T> Func1<T, Boolean> accumulate(final ArrayList<T> list) {
368+
return new Func1<T, Boolean>() {
369369

370370
@Override
371-
public Boolean call(Object t1) {
371+
public Boolean call(T t1) {
372372
list.add(t1);
373373
return true;
374374
}

0 commit comments

Comments
 (0)