Java 类rx.functions.Functions 实例源码

项目：RxJavaFlow 文件：OperatorZipTest.java

@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));
}

项目：newts 文件：ImportRunner.java

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());


    }

项目：rxjava-web-server 文件：Request.java

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();
}

项目：org.openntf.domino 文件：OperatorSequenceEqual.java

/**
 * 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());
}

项目：letv 文件：Observable.java

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));
}

项目：letv 文件：Observable.java

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));
}

项目：letv 文件：Observable.java

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));
}

项目：letv 文件：Observable.java

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));
}

项目：letv 文件：Observable.java

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));
}

项目：letv 文件：Observable.java

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));
}

项目：letv 文件：Observable.java

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));
}

项目：letv 文件：Observable.java

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));
}

项目：boohee_v5.6 文件：OperatorZip.java

public OperatorZip(Func2 f) {
    this.zipFunction = Functions.fromFunc(f);
}

项目：boohee_v5.6 文件：OperatorZip.java

public OperatorZip(Func3 f) {
    this.zipFunction = Functions.fromFunc(f);
}

项目：boohee_v5.6 文件：OperatorZip.java

public OperatorZip(Func4 f) {
    this.zipFunction = Functions.fromFunc(f);
}

项目：boohee_v5.6 文件：OperatorZip.java

public OperatorZip(Func5 f) {
    this.zipFunction = Functions.fromFunc(f);
}

项目：boohee_v5.6 文件：OperatorZip.java

public OperatorZip(Func6 f) {
    this.zipFunction = Functions.fromFunc(f);
}

项目：boohee_v5.6 文件：OperatorZip.java

public OperatorZip(Func7 f) {
    this.zipFunction = Functions.fromFunc(f);
}

项目：boohee_v5.6 文件：OperatorZip.java

public OperatorZip(Func8 f) {
    this.zipFunction = Functions.fromFunc(f);
}

项目：boohee_v5.6 文件：OperatorZip.java

public OperatorZip(Func9 f) {
    this.zipFunction = Functions.fromFunc(f);
}

项目：boohee_v5.6 文件：Observable.java

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));
}

项目：boohee_v5.6 文件：Observable.java

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));
}

项目：boohee_v5.6 文件：Observable.java

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));
}

项目：boohee_v5.6 文件：Observable.java

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));
}

项目：boohee_v5.6 文件：Observable.java

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));
}

项目：boohee_v5.6 文件：Observable.java

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));
}

项目：boohee_v5.6 文件：Observable.java

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));
}

项目：boohee_v5.6 文件：Observable.java

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));
}

项目：RxJavaFlow 文件：OperatorZip.java

@SuppressWarnings({ "unchecked", "rawtypes" })
public OperatorZip(BiFunction f) {
    this.zipFunction = Functions.fromFunc(f);
}

项目：RxJavaFlow 文件：OperatorZip.java

@SuppressWarnings({ "unchecked", "rawtypes" })
public OperatorZip(Func3 f) {
    this.zipFunction = Functions.fromFunc(f);
}

项目：RxJavaFlow 文件：OperatorZip.java

@SuppressWarnings({ "unchecked", "rawtypes" })
public OperatorZip(Func4 f) {
    this.zipFunction = Functions.fromFunc(f);
}

项目：RxJavaFlow 文件：OperatorZip.java

@SuppressWarnings({ "unchecked", "rawtypes" })
public OperatorZip(Func5 f) {
    this.zipFunction = Functions.fromFunc(f);
}

项目：RxJavaFlow 文件：OperatorZip.java

@SuppressWarnings({ "unchecked", "rawtypes" })
public OperatorZip(Func6 f) {
    this.zipFunction = Functions.fromFunc(f);
}

项目：RxJavaFlow 文件：OperatorZip.java

@SuppressWarnings({ "unchecked", "rawtypes" })
public OperatorZip(Func7 f) {
    this.zipFunction = Functions.fromFunc(f);
}

项目：RxJavaFlow 文件：OperatorZip.java

@SuppressWarnings({ "unchecked", "rawtypes" })
public OperatorZip(Func8 f) {
    this.zipFunction = Functions.fromFunc(f);
}

项目：RxJavaFlow 文件：OperatorZip.java

@SuppressWarnings({ "unchecked", "rawtypes" })
public OperatorZip(Func9 f) {
    this.zipFunction = Functions.fromFunc(f);
}

项目：org.openntf.domino 文件：OperatorZip.java

@SuppressWarnings({ "unchecked", "rawtypes" })
public OperatorZip(Func2 f) {
    this.zipFunction = Functions.fromFunc(f);
}

项目：org.openntf.domino 文件：OperatorZip.java

@SuppressWarnings({ "unchecked", "rawtypes" })
public OperatorZip(Func3 f) {
    this.zipFunction = Functions.fromFunc(f);
}

项目：org.openntf.domino 文件：OperatorZip.java

@SuppressWarnings({ "unchecked", "rawtypes" })
public OperatorZip(Func4 f) {
    this.zipFunction = Functions.fromFunc(f);
}

项目：org.openntf.domino 文件：OperatorZip.java

@SuppressWarnings({ "unchecked", "rawtypes" })
public OperatorZip(Func5 f) {
    this.zipFunction = Functions.fromFunc(f);
}