小利不争，小忿不发，可以合众。——傅昭

今天分享一个异步方法转Mono的方式，利用reactor.core.publisher.Mono#create：

1
2
3
4
5
6
7
8
9
10
11
return Mono.create(sink -> rtmClient.subscribe(channelName, options, new ResultCallback<Void>() {
    @Override
    public void onSuccess(Void unused) {
        sink.success(unused);
    }

    @Override
    public void onFailure(ErrorInfo errorInfo) {
        sink.error(new IllegalStateException(errorInfo.getErrorReason()));
    }
}));

即可实现