Streaming support for distributed collections such as ConsistentMap

Currently operations such as keySet, entrySet and values in ConsistentMap require a scan through the entire map (across all partitions) and returns the entire collection. A more scalable approach would be to support ability to stream through a collection. This poses some interesting challenges as state needs to be maintained for each individual stream that is open.