本文整理了Java中org.reactivestreams.Processor.onComplete()
方法的一些代码示例,展示了Processor.onComplete()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Processor.onComplete()
方法的具体详情如下:
包路径:org.reactivestreams.Processor
类名称:Processor
方法名:onComplete
暂无
代码示例来源:origin: micronaut-projects/micronaut-core
@Override
public void onComplete() {
processor.onComplete();
}
}
代码示例来源:origin: ReactiveX/RxJava
@Override
public void onComplete() {
Processor<T, T> w = window;
if (w != null) {
window = null;
w.onComplete();
}
downstream.onComplete();
}
代码示例来源:origin: ReactiveX/RxJava
@Override
public void onComplete() {
Processor<T, T> w = window;
if (w != null) {
window = null;
w.onComplete();
}
downstream.onComplete();
}
代码示例来源:origin: redisson/redisson
@Override
public void onComplete() {
Processor<T, T> w = window;
if (w != null) {
window = null;
w.onComplete();
}
actual.onComplete();
}
代码示例来源:origin: redisson/redisson
@Override
public void onComplete() {
Processor<T, T> w = window;
if (w != null) {
window = null;
w.onComplete();
}
actual.onComplete();
}
代码示例来源:origin: ReactiveX/RxJava
@Override
public void onComplete() {
if (done) {
return;
}
for (Processor<T, T> w : windows) {
w.onComplete();
}
windows.clear();
done = true;
drain();
}
代码示例来源:origin: reactor/reactor-core
@Override
public void onComplete() {
if (done) {
return;
}
done = true;
Processor<T, T> w = window;
if (w != null) {
window = null;
w.onComplete();
}
actual.onComplete();
}
代码示例来源:origin: reactor/reactor-core
@Override
public void onComplete() {
if (done) {
return;
}
done = true;
Processor<T, T> w = window;
if (w != null) {
window = null;
w.onComplete();
}
actual.onComplete();
}
代码示例来源:origin: ReactiveX/RxJava
/**
* Emit the given values and complete the Processor.
* @param <T> the value type
* @param p the target processor
* @param values the values to emit
*/
public static <T> void emit(Processor<T, ?> p, T... values) {
for (T v : values) {
p.onNext(v);
}
p.onComplete();
}
代码示例来源:origin: redisson/redisson
@Override
public void onComplete() {
if (done) {
return;
}
for (Processor<T, T> w : windows) {
w.onComplete();
}
windows.clear();
done = true;
drain();
}
代码示例来源:origin: reactor/reactor-core
@Override
public void onComplete() {
if (done) {
return;
}
done = true;
for (Processor<T, T> w : this) {
w.onComplete();
}
clear();
drain();
}
代码示例来源:origin: ReactiveX/RxJava
w.onComplete();
代码示例来源:origin: redisson/redisson
w.onComplete();
代码示例来源:origin: reactor/reactor-core
w.onComplete();
代码示例来源:origin: rsocket/rsocket-java
private void handleSendProcessorCancel(SignalType t) {
if (SignalType.ON_ERROR == t) {
return;
}
sendingSubscriptions.values().forEach(subscription -> {
try {
subscription.cancel();
} catch (Throwable e) {
errorConsumer.accept(e);
}
});
channelProcessors.values().forEach(subscription -> {
try {
subscription.onComplete();
} catch (Throwable e) {
errorConsumer.accept(e);
}
});
}
代码示例来源:origin: akaita/RxJava2Debug
/**
* Emit the given values and complete the Processor.
* @param <T> the value type
* @param p the target processor
* @param values the values to emit
*/
public static <T> void emit(Processor<T, ?> p, T... values) {
for (T v : values) {
p.onNext(v);
}
p.onComplete();
}
代码示例来源:origin: akarnokd/RxJava2Extensions
@Override
public void onComplete() {
done = true;
source.onComplete();
}
代码示例来源:origin: com.github.akarnokd/rxjava2-extensions
@Override
public void onComplete() {
done = true;
source.onComplete();
}
代码示例来源:origin: akarnokd/RxJava2Extensions
@Override
public void onComplete() {
Processor<T, T> w = window;
if (w != null) {
window = null;
w.onComplete();
}
downstream.onComplete();
}
代码示例来源:origin: reactor/reactor-netty
@After
public void clean() {
processor.onComplete();
httpServer.disposeNow();
}
内容来源于网络,如有侵权,请联系作者删除!