After changing Producer-Consumer API to Streams.