krasserm/streamz

Why does Keep.none affect materialized (CE3 branch)

Swoorup opened this issue · 0 comments

It appears that when converting from fs2 to akka streams, you would need to wait for the materialized value? If you instead use Keep.none the stream isn't executed at all.

This is different to the default behaviour in Akka, the stream executes despite the materialized value being discarded.

Repro sample: https://scastie.scala-lang.org/VvAJ9hZHQBSJ4jYJBRjM3A
Uncomment the akka sink to see the result without fs2 streams.