Re: Rich variant for Async IO in Scala

[Timo Walther]

Hi Bruno,

`org.apache.flink.streaming.api.functions.async.RichAsyncFunction` 
should also work for the Scala API. `RichMapFunction` or 
`RichFilterFunction` are also shared between both APIs.

Is there anything that blocks you from using it?

Regards,
Timo

Am 09.11.18 um 01:38 schrieb Bruno Aranda:
Hi,

I see that the AsyncFunction for Scala does not seem to have a rich 
variant like the Java one. Is there a particular reason for this? Is 
there any workaround?

Thanks!

Bruno