4.9. Eclipse Vert.x Reactive Extensions (Rx) の変更点

Eclipse Vert.x 4.1.0 以降では、RxJava 3 がサポートされます。

RxJava 3 にアップグレードするには、次の変更を行う必要があります。

WriteStreamSubscriber.onComplete() コールバックが削除されました。このコールバックは、WriteStream が書き込まれるデータのストリームが保留中の場合に呼び出されました。

Eclipse Vert.x 4 では、代わりに WriteStreamSubscriber.onWriteStreamEnd() コールバックおよび WriteStreamSubscriber.onWriteStreamError() コールバックを使用します。これらのコールバックは、WriteStream.end() の完了後に呼び出されます。

WriteStreamSubscriber<Buffer> subscriber = writeStream.toSubscriber();

以下の例は、Eclipse Vert.x 3.x リリースの WriteStream からアダプターを作成する方法を示しています。

subscriber.onComplete(() -> {
    // Called after writeStream.end() is invoked, even if operation has not completed
});

以下の例は、Eclipse Vert.x 4 リリースの新しいコールバックメソッドを使用して WriteStream からアダプターを作成する方法を示しています。

subscriber.onWriteStreamEnd(() -> {
    // Called after writeStream.end() is invoked and completes successfully
});

subscriber.onWriteStreamError(() -> {
    // Called after writeStream.end() is invoked and fails
});