Re: [infinispan-dev] Distributed Streams
On Mon, Jul 13, 2015 at 9:30 PM, Tristan Tarrant <ttarrant(a)redhat.com> wrote:
On 10/07/2015 00:10, Galder Zamarreno wrote:
>> After the discussion we started in Galder's PR's comments [1], I
>> started thinking that we should really have a stream() method directly
>> in the Cache/AdvancedCache interface.
>
> ^ I don't think that's a good idea. A stream of what? keys only? values and
keys?
>
> In the end you'd end up with 2/3 stream methods....
I agree with Galder here: streams only apply to Collections and not to
Maps (like in the JDK). It has already proven difficult mimicking the
Map interface in a distributed environment: let's not aggravate this.
entrySet().stream(), keySet().stream() are unambiguous and respect the
original interfaces.
I was thinking stream() would stream CacheEntries, like
cacheEntrySet().stream() does in Will's PR. But I guess people who
want to try the streaming API will still go for entrySet().stream()
first, and they'll only try to find another method if it doesn't work
or if they need access to the metadata.
Dan