io.reactivex.functions.Function.apply()方法的使用及代码示例

本文整理了Java中io.reactivex.functions.Function.apply()方法的一些代码示例，展示了Function.apply()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Function.apply()方法的具体详情如下：
包路径：io.reactivex.functions.Function
类名称：Function
方法名：apply

Function.apply介绍

[英]Apply some calculation to the input value and return some other value.
[中]对输入值应用一些计算并返回一些其他值。

代码示例

代码示例来源：origin: ReactiveX/RxJava

@Override
public void accept(Map m, T t) throws Exception {
K key = keySelector.apply(t);
V value = valueSelector.apply(t);
m.put(key, value);
}
}

代码示例来源：origin: ReactiveX/RxJava

@Override
public Publisher apply(T t) throws Exception {
return new FlowableFromIterable(ObjectHelper.requireNonNull(mapper.apply(t), "The mapper returned a null Iterable"));
}
}

代码示例来源：origin: ReactiveX/RxJava

@Override
public ObservableSource apply(T t) throws Exception {
return new ObservableFromIterable(ObjectHelper.requireNonNull(mapper.apply(t), "The mapper returned a null Iterable"));
}
}

代码示例来源：origin: ReactiveX/RxJava

@Nullable
@Override
public T poll() throws Exception {
for (;;) {
T v = qd.poll();
if (v == null || collection.add(ObjectHelper.requireNonNull(keySelector.apply(v), "The keySelector returned a null key"))) {
return v;
}
}
}

代码示例来源：origin: ReactiveX/RxJava

public O x(Function, O> operator) {
try {
return operator.apply(onSubscribe);
} catch (Throwable ex) {
throw ExceptionHelper.wrapOrThrow(ex);
}
}

代码示例来源：origin: ReactiveX/RxJava

@Nullable
@Override
public U poll() throws Exception {
T t = qd.poll();
return t != null ? ObjectHelper.requireNonNull(mapper.apply(t), "The mapper function returned a null value.") : null;
}
}

代码示例来源：origin: ReactiveX/RxJava

public CylonDetectorObservable compose(Function, CylonDetectorObservable> transformer) {
try {
return transformer.apply(this);
} catch (Throwable ex) {
throw ExceptionHelper.wrapOrThrow(ex);
}
}

代码示例来源：origin: ReactiveX/RxJava

@Override
public ObservableSource apply(final T t) throws Exception {
@SuppressWarnings("unchecked")
ObservableSource u = (ObservableSource)ObjectHelper.requireNonNull(mapper.apply(t), "The mapper returned a null ObservableSource");
return new ObservableMap(u, new FlatMapWithCombinerInner(combiner, t));
}
}

代码示例来源：origin: ReactiveX/RxJava

@Override
public void onSuccess(S value) {
Publisher f;
try {
f = ObjectHelper.requireNonNull(mapper.apply(value), "the mapper returned a null Publisher");
} catch (Throwable e) {
Exceptions.throwIfFatal(e);
downstream.onError(e);
return;
}
f.subscribe(this);
}

代码示例来源：origin: ReactiveX/RxJava

@Override
public void onSuccess(T value) {
R v;
try {
v = ObjectHelper.requireNonNull(mapper.apply(value), "The mapper function returned a null value.");
} catch (Throwable e) {
Exceptions.throwIfFatal(e);
onError(e);
return;
}
t.onSuccess(v);
}

代码示例来源：origin: ReactiveX/RxJava

public SchedulerWhen(Function>, Completable> combine, Scheduler actualScheduler) {
this.actualScheduler = actualScheduler;
// workers are converted into completables and put in this queue.
this.workerProcessor = UnicastProcessor.>create().toSerialized();
// send it to a custom combinator to pick the order and rate at which
// workers are processed.
try {
disposable = combine.apply(workerProcessor).subscribe();
} catch (Throwable e) {
throw ExceptionHelper.wrapOrThrow(e);
}
}

代码示例来源：origin: ReactiveX/RxJava

@Override
public Publisher apply(final T v) throws Exception {
Publisher p = ObjectHelper.requireNonNull(itemDelay.apply(v), "The itemDelay returned a null Publisher");
return new FlowableTakePublisher(p, 1).map(Functions.justFunction(v)).defaultIfEmpty(v);
}
}

代码示例来源：origin: ReactiveX/RxJava

@Override
public void onError(Throwable t) {
R p;
try {
p = ObjectHelper.requireNonNull(onErrorMapper.apply(t), "The onError publisher returned is null");
} catch (Throwable e) {
Exceptions.throwIfFatal(e);
downstream.onError(new CompositeException(t, e));
return;
}
complete(p);
}

代码示例来源：origin: ReactiveX/RxJava

@Override
public T next() {
if (--crashOnNext <= 0) {
throw new TestException("next()");
}
try {
return mapper.apply(count++);
} catch (Throwable ex) {
throw ExceptionHelper.wrapOrThrow(ex);
}
}

代码示例来源：origin: ReactiveX/RxJava

@Override
public void onError(Throwable e) {
T v;
try {
v = ObjectHelper.requireNonNull(valueSupplier.apply(e), "The valueSupplier returned a null value");
} catch (Throwable ex) {
Exceptions.throwIfFatal(ex);
downstream.onError(new CompositeException(e, ex));
return;
}
downstream.onSuccess(v);
}

代码示例来源：origin: ReactiveX/RxJava

@Override
public void onSuccess(T value) {
MaybeSource source;
try {
source = ObjectHelper.requireNonNull(onSuccessMapper.apply(value), "The onSuccessMapper returned a null MaybeSource");
} catch (Exception ex) {
Exceptions.throwIfFatal(ex);
downstream.onError(ex);
return;
}
source.subscribe(new InnerObserver());
}

代码示例来源：origin: ReactiveX/RxJava

@Test(expected = IllegalArgumentException.class)
public void toFunction3() throws Exception {
Functions.toFunction(new Function3() {
@Override
public Integer apply(Integer t1, Integer t2, Integer t3) throws Exception {
return null;
}
}).apply(new Object[20]);
}

代码示例来源：origin: ReactiveX/RxJava

@Test(expected = IllegalArgumentException.class)
public void toFunction4() throws Exception {
Functions.toFunction(new Function4() {
@Override
public Integer apply(Integer t1, Integer t2, Integer t3, Integer t4) throws Exception {
return null;
}
}).apply(new Object[20]);
}

代码示例来源：origin: ReactiveX/RxJava

@Override
public void run() {
System.out.println(scheduler.now(TimeUnit.MILLISECONDS));
try {
calledOp.apply(scheduler.now(TimeUnit.MILLISECONDS));
} catch (Throwable ex) {
ExceptionHelper.wrapOrThrow(ex);
}
}
}, 1, 2, TimeUnit.SECONDS);

代码示例来源：origin: ReactiveX/RxJava

@Override
public void onError(Throwable e) {
MaybeSource source;
try {
source = ObjectHelper.requireNonNull(onErrorMapper.apply(e), "The onErrorMapper returned a null MaybeSource");
} catch (Exception ex) {
Exceptions.throwIfFatal(ex);
downstream.onError(new CompositeException(e, ex));
return;
}
source.subscribe(new InnerObserver());
}