Did you send any elements to the stream? internalCounter is incremented in
the map operator for every incoming stream element.
Trait is only used to hide the implementation details of the counter.
On Thu, Nov 1, 2018 at 12:04 AM wrote:
> Hi Rafal,
>
> I just stumbled upon your reply. Could you
Here is a quick scalafiddle that runs the code from 2 years ago :)
https://scalafiddle.io/sf/xaGO6Yr/0
On Mon, Nov 5, 2018 at 8:18 AM Martynas Mickevičius <2...@lightbend.com>
wrote:
> Did you send any elements to the stream? internalCounter is incremented
> in the map operator for every incomin
