OperationToMap { public static <T, K> OnSubscribeFunc<Map<K, T>> toMap(Observable<T> source, Func1<? super T, ? extends K> keySelector) { return new ToMap<T, K, T>(source, keySelector, Functions.<T> identity(), new DefaultToMapFactory<K, T>()); }  static OnSubscribeFunc<Map<K, T>> toMap(Observable<T> source,
            Func1<? super T, ? extends K> keySelector); static OnSubscribeFunc<Map<K, V>> toMap(Observable<T> source,
            Func1<? super T, ? extends K> keySelector,
            Func1<? super T, ? extends V> valueSelector); static OnSubscribeFunc<Map<K, V>> toMap(Observable<T> source,
            Func1<? super T, ? extends K> keySelector,
            Func1<? super T, ? extends V> valueSelector,
            Func0<? extends Map<K, V>> mapFactory);  }
@Test public void testToMap() { Observable<String> source = Observable.from("a", "bb", "ccc", "dddd"); Observable<Map<Integer, String>> mapped = Observable.create(OperationToMap.toMap(source, lengthFunc)); Map<Integer, String> expected = new HashMap<Integer, String>(); expected.put(1, "a"); expected.put(2, "bb"); expected.put(3, "ccc"); expected.put(4, "dddd"); mapped.subscribe(objectObserver); verify(objectObserver, never()).onError(any(Throwable.class)); verify(objectObserver, times(1)).onNext(expected); verify(objectObserver, times(1)).onCompleted(); }
@Test public void testToMapWithValueSelector() { Observable<String> source = Observable.from("a", "bb", "ccc", "dddd"); Observable<Map<Integer, String>> mapped = Observable.create(OperationToMap.toMap(source, lengthFunc, duplicate)); Map<Integer, String> expected = new HashMap<Integer, String>(); expected.put(1, "aa"); expected.put(2, "bbbb"); expected.put(3, "cccccc"); expected.put(4, "dddddddd"); mapped.subscribe(objectObserver); verify(objectObserver, never()).onError(any(Throwable.class)); verify(objectObserver, times(1)).onNext(expected); verify(objectObserver, times(1)).onCompleted(); }
@Test public void testToMapWithError() { Observable<String> source = Observable.from("a", "bb", "ccc", "dddd"); Func1<String, Integer> lengthFuncErr = new Func1<String, Integer>() { @Override public Integer call(String t1) { if ("bb".equals(t1)) { throw new RuntimeException("Forced Failure"); } return t1.length(); } }; Observable<Map<Integer, String>> mapped = Observable.create(OperationToMap.toMap(source, lengthFuncErr)); Map<Integer, String> expected = new HashMap<Integer, String>(); expected.put(1, "a"); expected.put(2, "bb"); expected.put(3, "ccc"); expected.put(4, "dddd"); mapped.subscribe(objectObserver); verify(objectObserver, never()).onNext(expected); verify(objectObserver, never()).onCompleted(); verify(objectObserver, times(1)).onError(any(Throwable.class)); }
@Test public void testToMapWithErrorInValueSelector() { Observable<String> source = Observable.from("a", "bb", "ccc", "dddd"); Func1<String, String> duplicateErr = new Func1<String, String>() { @Override public String call(String t1) { if ("bb".equals(t1)) { throw new RuntimeException("Forced failure"); } return t1 + t1; } }; Observable<Map<Integer, String>> mapped = Observable.create(OperationToMap.toMap(source, lengthFunc, duplicateErr)); Map<Integer, String> expected = new HashMap<Integer, String>(); expected.put(1, "aa"); expected.put(2, "bbbb"); expected.put(3, "cccccc"); expected.put(4, "dddddddd"); mapped.subscribe(objectObserver); verify(objectObserver, never()).onNext(expected); verify(objectObserver, never()).onCompleted(); verify(objectObserver, times(1)).onError(any(Throwable.class)); }
@Test public void testToMapWithFactory() { Observable<String> source = Observable.from("a", "bb", "ccc", "dddd"); Func0<Map<Integer, String>> mapFactory = new Func0<Map<Integer, String>>() { @Override public Map<Integer, String> call() { return new LinkedHashMap<Integer, String>() { @Override protected boolean removeEldestEntry(Map.Entry<Integer, String> eldest) { return size() > 3; } }; } }; Func1<String, Integer> lengthFunc = new Func1<String, Integer>() { @Override public Integer call(String t1) { return t1.length(); } }; Observable<Map<Integer, String>> mapped = Observable.create(OperationToMap.toMap(source, lengthFunc, Functions.<String> identity(), mapFactory)); Map<Integer, String> expected = new LinkedHashMap<Integer, String>(); expected.put(2, "bb"); expected.put(3, "ccc"); expected.put(4, "dddd"); mapped.subscribe(objectObserver); verify(objectObserver, never()).onError(any(Throwable.class)); verify(objectObserver, times(1)).onNext(expected); verify(objectObserver, times(1)).onCompleted(); }
@Test public void testToMapWithErrorThrowingFactory() { Observable<String> source = Observable.from("a", "bb", "ccc", "dddd"); Func0<Map<Integer, String>> mapFactory = new Func0<Map<Integer, String>>() { @Override public Map<Integer, String> call() { throw new RuntimeException("Forced failure"); } }; Func1<String, Integer> lengthFunc = new Func1<String, Integer>() { @Override public Integer call(String t1) { return t1.length(); } }; Observable<Map<Integer, String>> mapped = Observable.create(OperationToMap.toMap(source, lengthFunc, Functions.<String> identity(), mapFactory)); Map<Integer, String> expected = new LinkedHashMap<Integer, String>(); expected.put(2, "bb"); expected.put(3, "ccc"); expected.put(4, "dddd"); mapped.subscribe(objectObserver); verify(objectObserver, never()).onNext(expected); verify(objectObserver, never()).onCompleted(); verify(objectObserver, times(1)).onError(any(Throwable.class)); }