@SuppressWarnings("unchecked") @Test public void testCollectionSizeDifferentThanFunction() { FuncN<String> zipr = Functions.fromFunc(getConcatStringIntegerIntArrayZipr()); //Func3<String, Integer, int[], String> /* define a Observer to receive aggregated events */ Observer<String> observer = mock(Observer.class); @SuppressWarnings("rawtypes") Collection ws = java.util.Collections.singleton(Observable.just("one", "two")); Observable<String> w = Observable.zip(ws, zipr); w.subscribe(observer); verify(observer, times(1)).onError(any(Throwable.class)); verify(observer, never()).onComplete(); verify(observer, never()).onNext(any(String.class)); }
private Observable<Boolean> directPoster(Observable<List<Sample>> samples, MetricRegistry metrics) { final SampleRepository repository = repository(); final Timer timer = metrics.timer("writes"); final Meter completions = metrics.meter("samples-completed"); Func1<List<Sample>, Boolean> insert = new Func1<List<Sample>, Boolean>() { @Override public Boolean call(List<Sample> s) { int sz = s.size(); try (Context timerCtx = timer.time()) { repository.insert(s); return true; } finally { completions.mark(sz); } } }; return (m_threadCount == 1 ? samples.map(insert) : parMap(samples, metrics, insert)).all(Functions.<Boolean>identity()); }
public Observable<String> getHeader(String key) { return map // select MethodLine line .filter(byKey("MethodLine")) // flatten .flatMap(Functions.<Observable<Header>> identity()) // to value .map(toValue) // cache result .cache(); }
/** * Tests whether two {@code Observable} sequences are identical, emitting {@code true} if both sequences * complete without differing, and {@code false} if the two sequences diverge at any point. * * @param first * the first of the two {@code Observable}s to compare * @param second * the second of the two {@code Observable}s to compare * @param equality * a function that tests emissions from each {@code Observable} for equality * @return an {@code Observable} that emits {@code true} if {@code first} and {@code second} complete * after emitting equal sequences of items, {@code false} if at any point in their sequences the * two {@code Observable}s emit a non-equal item. */ public static <T> Observable<Boolean> sequenceEqual( Observable<? extends T> first, Observable<? extends T> second, final Func2<? super T, ? super T, Boolean> equality) { Observable<Object> firstObservable = materializeLite(first); Observable<Object> secondObservable = materializeLite(second); return zip(firstObservable, secondObservable, new Func2<Object, Object, Boolean>() { @Override @SuppressWarnings("unchecked") public Boolean call(Object t1, Object t2) { boolean c1 = t1 == LOCAL_ONCOMPLETED; boolean c2 = t2 == LOCAL_ONCOMPLETED; if (c1 && c2) { return true; } if (c1 || c2) { return false; } // Now t1 and t2 must be 'onNext'. return equality.call((T)t1, (T)t2); } }).all(Functions.<Boolean> identity()); }
public static <T1, T2, R> Observable<R> combineLatest(Observable<? extends T1> o1, Observable<? extends T2> o2, Func2<? super T1, ? super T2, ? extends R> combineFunction) { return combineLatest(Arrays.asList(new Observable[]{o1, o2}), Functions.fromFunc(combineFunction)); }
public static <T1, T2, T3, R> Observable<R> combineLatest(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Func3<? super T1, ? super T2, ? super T3, ? extends R> combineFunction) { return combineLatest(Arrays.asList(new Observable[]{o1, o2, o3}), Functions.fromFunc(combineFunction)); }
public static <T1, T2, T3, T4, R> Observable<R> combineLatest(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Func4<? super T1, ? super T2, ? super T3, ? super T4, ? extends R> combineFunction) { return combineLatest(Arrays.asList(new Observable[]{o1, o2, o3, o4}), Functions.fromFunc(combineFunction)); }
public static <T1, T2, T3, T4, T5, R> Observable<R> combineLatest(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Observable<? extends T5> o5, Func5<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? extends R> combineFunction) { return combineLatest(Arrays.asList(new Observable[]{o1, o2, o3, o4, o5}), Functions.fromFunc(combineFunction)); }
public static <T1, T2, T3, T4, T5, T6, R> Observable<R> combineLatest(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Observable<? extends T5> o5, Observable<? extends T6> o6, Func6<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? extends R> combineFunction) { return combineLatest(Arrays.asList(new Observable[]{o1, o2, o3, o4, o5, o6}), Functions.fromFunc(combineFunction)); }
public static <T1, T2, T3, T4, T5, T6, T7, R> Observable<R> combineLatest(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Observable<? extends T5> o5, Observable<? extends T6> o6, Observable<? extends T7> o7, Func7<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? extends R> combineFunction) { return combineLatest(Arrays.asList(new Observable[]{o1, o2, o3, o4, o5, o6, o7}), Functions.fromFunc(combineFunction)); }
public static <T1, T2, T3, T4, T5, T6, T7, T8, R> Observable<R> combineLatest(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Observable<? extends T5> o5, Observable<? extends T6> o6, Observable<? extends T7> o7, Observable<? extends T8> o8, Func8<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? extends R> combineFunction) { return combineLatest(Arrays.asList(new Observable[]{o1, o2, o3, o4, o5, o6, o7, o8}), Functions.fromFunc(combineFunction)); }
public static <T1, T2, T3, T4, T5, T6, T7, T8, T9, R> Observable<R> combineLatest(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Observable<? extends T5> o5, Observable<? extends T6> o6, Observable<? extends T7> o7, Observable<? extends T8> o8, Observable<? extends T9> o9, Func9<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? super T9, ? extends R> combineFunction) { return combineLatest(Arrays.asList(new Observable[]{o1, o2, o3, o4, o5, o6, o7, o8, o9}), Functions.fromFunc(combineFunction)); }
public OperatorZip(Func2 f) { this.zipFunction = Functions.fromFunc(f); }
public OperatorZip(Func3 f) { this.zipFunction = Functions.fromFunc(f); }
public OperatorZip(Func4 f) { this.zipFunction = Functions.fromFunc(f); }
public OperatorZip(Func5 f) { this.zipFunction = Functions.fromFunc(f); }
public OperatorZip(Func6 f) { this.zipFunction = Functions.fromFunc(f); }
public OperatorZip(Func7 f) { this.zipFunction = Functions.fromFunc(f); }
public OperatorZip(Func8 f) { this.zipFunction = Functions.fromFunc(f); }
public OperatorZip(Func9 f) { this.zipFunction = Functions.fromFunc(f); }
public static final <T1, T2, R> Observable<R> combineLatest(Observable<? extends T1> o1, Observable<? extends T2> o2, Func2<? super T1, ? super T2, ? extends R> combineFunction) { return combineLatest(Arrays.asList(new Observable[]{o1, o2}), Functions.fromFunc(combineFunction)); }
public static final <T1, T2, T3, R> Observable<R> combineLatest(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Func3<? super T1, ? super T2, ? super T3, ? extends R> combineFunction) { return combineLatest(Arrays.asList(new Observable[]{o1, o2, o3}), Functions.fromFunc(combineFunction)); }
public static final <T1, T2, T3, T4, R> Observable<R> combineLatest(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Func4<? super T1, ? super T2, ? super T3, ? super T4, ? extends R> combineFunction) { return combineLatest(Arrays.asList(new Observable[]{o1, o2, o3, o4}), Functions.fromFunc(combineFunction)); }
public static final <T1, T2, T3, T4, T5, R> Observable<R> combineLatest(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Observable<? extends T5> o5, Func5<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? extends R> combineFunction) { return combineLatest(Arrays.asList(new Observable[]{o1, o2, o3, o4, o5}), Functions.fromFunc(combineFunction)); }
public static final <T1, T2, T3, T4, T5, T6, R> Observable<R> combineLatest(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Observable<? extends T5> o5, Observable<? extends T6> o6, Func6<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? extends R> combineFunction) { return combineLatest(Arrays.asList(new Observable[]{o1, o2, o3, o4, o5, o6}), Functions.fromFunc(combineFunction)); }
public static final <T1, T2, T3, T4, T5, T6, T7, R> Observable<R> combineLatest(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Observable<? extends T5> o5, Observable<? extends T6> o6, Observable<? extends T7> o7, Func7<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? extends R> combineFunction) { return combineLatest(Arrays.asList(new Observable[]{o1, o2, o3, o4, o5, o6, o7}), Functions.fromFunc(combineFunction)); }
public static final <T1, T2, T3, T4, T5, T6, T7, T8, R> Observable<R> combineLatest(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Observable<? extends T5> o5, Observable<? extends T6> o6, Observable<? extends T7> o7, Observable<? extends T8> o8, Func8<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? extends R> combineFunction) { return combineLatest(Arrays.asList(new Observable[]{o1, o2, o3, o4, o5, o6, o7, o8}), Functions.fromFunc(combineFunction)); }
public static final <T1, T2, T3, T4, T5, T6, T7, T8, T9, R> Observable<R> combineLatest(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Observable<? extends T5> o5, Observable<? extends T6> o6, Observable<? extends T7> o7, Observable<? extends T8> o8, Observable<? extends T9> o9, Func9<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? super T9, ? extends R> combineFunction) { return combineLatest(Arrays.asList(new Observable[]{o1, o2, o3, o4, o5, o6, o7, o8, o9}), Functions.fromFunc(combineFunction)); }
@SuppressWarnings({ "unchecked", "rawtypes" }) public OperatorZip(BiFunction f) { this.zipFunction = Functions.fromFunc(f); }
@SuppressWarnings({ "unchecked", "rawtypes" }) public OperatorZip(Func3 f) { this.zipFunction = Functions.fromFunc(f); }
@SuppressWarnings({ "unchecked", "rawtypes" }) public OperatorZip(Func4 f) { this.zipFunction = Functions.fromFunc(f); }
@SuppressWarnings({ "unchecked", "rawtypes" }) public OperatorZip(Func5 f) { this.zipFunction = Functions.fromFunc(f); }
@SuppressWarnings({ "unchecked", "rawtypes" }) public OperatorZip(Func6 f) { this.zipFunction = Functions.fromFunc(f); }
@SuppressWarnings({ "unchecked", "rawtypes" }) public OperatorZip(Func7 f) { this.zipFunction = Functions.fromFunc(f); }
@SuppressWarnings({ "unchecked", "rawtypes" }) public OperatorZip(Func8 f) { this.zipFunction = Functions.fromFunc(f); }
@SuppressWarnings({ "unchecked", "rawtypes" }) public OperatorZip(Func9 f) { this.zipFunction = Functions.fromFunc(f); }
@SuppressWarnings({ "unchecked", "rawtypes" }) public OperatorZip(Func2 f) { this.zipFunction = Functions.fromFunc(f); }