Added example collect for 2.4

Froussios · Froussios · commit b05874af50d5 · 2015-05-12T16:51:25.000+02:00
diff --git a/tests/java/itrx/chapter2/aggregation/CollectTest.java b/tests/java/itrx/chapter2/aggregation/CollectTest.java
@@ -0,0 +1,43 @@
+package itrx.chapter2.aggregation;
+
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.List;
+
+import org.junit.Test;
+
+import rx.Observable;
+import rx.observers.TestSubscriber;
+
+public class CollectTest {
+
+	public void example() {
+		Observable<Integer> values = Observable.range(10,5);
+		
+		values
+			.collect(
+				() -> new ArrayList<Integer>(),
+				(acc, value) -> acc.add(value))
+			.subscribe(v -> System.out.println(v));
+	}
+	
+	@Test
+	public void test() {
+		TestSubscriber<List<Integer>> tester = new TestSubscriber<>();
+		
+		Observable<Integer> values = Observable.range(10,5);
+		
+		values
+			.collect(
+				() -> new ArrayList<Integer>(),
+				(acc, value) -> acc.add(value))
+			.subscribe(tester);
+		
+		tester.assertReceivedOnNext(Arrays.asList(
+				Arrays.asList(10, 11, 12, 13, 14)
+		));
+		tester.assertTerminalEvent();
+		tester.assertNoErrors();
+	}
+
+}
