4.9. Eclipse Vert.x Reactive Extensions (Rx)中的更改

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

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

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

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

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

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

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

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