Step 1 of 4: Choose Issues

Cancel

Key Summary Description
ISPN-5805

ISPN-5626 Allow forEach consumer to have a Cache Injected

Cache Injection was purposely left out with distributed streams. This is due to map/reduce requiring CDI to do injection. Do we still want to do that or just do something simple like an extra interface?

ISPN-5662

ISPN-5626 Change stream timeout values for remote operations to use replication timeout

Currently the AbstractCacheStream and others have hard coded wait times for remote operation timeouts. We should instead change those to be the replication timeout values.

ISPN-5652

ISPN-5626 Change isEmpty to use anyMatch to prevent serializing entries

isEmpty should use anyMatch so that we don't have to serialize all of the iterated values across the stream and allows for short circuiting of loops.

ISPN-5632

ISPN-5626 Address rework comments for ISPN-5293

There are some new rework comments for https://github.com/infinispan/infinispan/pull/3569. This issue will cover those.

ISPN-5630

ISPN-5626 Port tests from enty retriever

This is to port the various entry retriever tests to get similar coverage for distributed streams.

Cancel