在 Project Loom 的虚拟线程上运行 Kotlin 协程
)
}
this .onError {
continuation.resumeWithException(exception = it)
}
this
1 年 前
WebSockets与服务器发送事件SSE比较
());
}
@OnError
public void onError(Throwable error) {
System.out.println("" + error
1 个月 前
征服并发 - 在安卓Android平台引入Rx:Reactive Ext
void onError(Throwable t) { … }
}
<p class="indent">
组合Composition实现如下
10 年 前
使用OpenTracing跟踪Go中的HTTP请求延迟
/", *serverPort),
nil,
)
if err != nil {
onError(span, err)
return
}
req
7 年 前
RxJava在安卓开发中应用源码
(){}
void onError(Exception e){}
void onNext(Object o){}
});
<p class = "indent" >
9 年 前
半同步/半异步模式
onPreCall ()} throw any exception.
*
* @param throwable error cause
*/
void onError
5 年 前
使用 Spring Retry 实现数据库连接重试案例
三个方法，我们可以覆盖这些方法来添加我们的自定义逻辑：
[list]
[*]onError - 当出现错误时调用该方法
[*]close- 当所有重试结束时调用该方法。
[*]open - 当
9 个月 前
Java 9新特点: 响应式流Reactive Streams
OnNext(T)，错误消息通过onError(Throwable)，如果只有一个消息，肯定不会没有更多的消息量使用oncomplete()。在这些任何的情况发生前，publisher需要调用
7 年 前
使用Node.js + RSocket + WebSocket + Spring Boot实现实时前后端通讯 - vinsguru
('number.stream'.length) + 'number.stream'
}).subscribe({
onError: errorHanlder,
onNext
3 年 前
Spring响应式Reactive编程的10个陷阱 -Jeroen Rosenberg
onError(Throwable t);
public void onComplete();
}
public interface Subscription
4 年 前
Spring WebFlux和Reactive编程
());
}
@Override
public void onError(Throwable t
5 年 前
使用RSocket进行服务通信的反应性服务简介 - Rafał Kowalski
。它也完全支持无功信号 - 我们可以轻松地对不同事件实现“反应” - onNext，onError，onClose等。 以下段落将介绍API和RSocket中可用的每个交互选项。讨论将以代码片段和所有示例
4 年 前
使用反应式编程替换Java自动资源管理 - Arvind
鼓励将编码模式限制为 aonSuccess()和onError()处理程序。这在 异步 处理的世界中成为绝对必须的，因为异常会发生在调用堆栈（即线程）上，而调用堆栈（即线程）与正在使用结果的调用堆栈
2 年 前
赶超Netty：基于Java19虚拟线程的Nima发布
results: " + it)
.onError(res::send)
.forSingle(res::send);
尽管我们用响应式代码实现了相同的效果，但代码的可读性
1 年 前
什么是流式思维？
.subscribe(Subscriber { //UI线程
void onComplete(){}
void onError(Exception e){}
void onNext(Object o
9 年 前