You can also issue multiple calls in one "invoke()" call (have multiple
Futures) and then chain these futures and return only something
once all Futures are complete.
On Mon, Feb 20, 2017 at 4:01 PM, Till Rohrmann wrote:
> In order to output 0 elements you have to pass an empty collection to the
In order to output 0 elements you have to pass an empty collection to the
`collect` method.
You're right that our online documentation is lacking the fact that you're
only supposed to call `collect` once. It's actually documented in the
JavaDocs of this method. We should change this.
You're also
Hi Till,
Thanks, for the explanation!
How do I express if I don't want to collect any elements in the async
collector? Like 0 output from a flatmap.
Also it doesn't seem to be specified anywhere that the AsyncCollector is
"completed", it is just a collector. You should be able to collect multipl
Hi Gyula,
the assumption is that the AsyncCollector is either completed by the user
or, if you have a timeout defined, that it will be completed with a timeout
exception. This means that if you have no timeout defined, then you have to
make sure that the collector is completed. Otherwise you will
Hi,
I was looking at the AsyncFunction interface and try to wrap my head around
the implementation and the assumptions and I have some questions, maybe
somebody could help me out :)
What happens if the user does not collect any data or set a future to do so
in the invoke method?
Also what happens
