Consume-Transform-(not always)Produce with Streams

Already solved this issue thanks to the discussion on link
:smile: