If you want to support cancelation, you can capture the `Future` from this and register it with the `Subscriber`.

For example:

```java
subscriber.add(Subscriptions.from(future));
```