Overload collect() to take Supplier and SerializableSupplier ------------------------------------------------------------ Key: ISPN-8281 URL: https://issues.jboss.org/browse/ISPN-8281 Project: Infinispan Issue Type: Enhancement Reporter: Galder Zamarreño Assignee: Galder Zamarreño Fix For: 9.2.0.Alpha2, 9.2.0.Final Whenever a collect() is called in a distributed environment, you have to wrap up in a serializable supplier method call to make it serializable, e.g. {code} Map<Integer, Long> totalPerHour = cache.values().stream() .collect( CacheCollectors.serializableCollector(() -> Collectors.groupingBy( e -> getHourOfDay(e.departureTs), Collectors.counting() ))); {code} This is a bit clunky. We should overload collect to take a SerializableSupplier in CacheStream. It would also be nice to have an overloaded version that takes Supplier in case you want to provide your own serialization for it.