ListenableFuture to Mono/Flux adapter

[reactor]

ListenableFuture to Mono/Flux adapter

[simonbasle]

@rstoyanchev we think that this should probably go into Spring 5 rather than on Reactor side, wdyt?

@jansyk13 in the meantime if you want to go from ListenableFuture to Mono in Spring 4 then using Mono.create is probably the best bet. Or attempting to convert to CompletableFuture first ...

[rstoyanchev]

Yes this would belong in the Spring Framework especially with Spring 5 using Reactor as a core dependency for the reactive support.

Note in the Spring Framework we've had since 4.2 a CompletableToListenableFutureAdapter so you can wrap the following in a convenient utility method:

Mono.fromFuture(new CompletableToListenableFutureAdapter(listenableFuture));

I'm wondering also what you are using that returns ListenableFuture? For example in Spring 5 we have a WebClient that returns Mono and Flux as the core type. That will be an alternative to the AsyncRestTempate which returns ListenableFuture and it's something you can try out already.

[kevinten10]

How about Guava's ListenableFuture adapter?