Uploaded image for project: 'Infinispan'
  1. Infinispan
  2. ISPN-8033

Distributed Stream rehash is broken if a map operation is used

    Details

      Description

      Rehash distributed streams are broken if an intermediate operation is present that has a map operation.

      cache.entrySet().stream().map(Map.Entry::getValue)
      

      This is due to the stream supplier doesn't create a new stream on each invocation in DistributionBulkInterceptor.

        Gliffy Diagrams

          Attachments

            Activity

              People

              • Assignee:
                william.burns Will Burns
                Reporter:
                william.burns Will Burns
              • Votes:
                0 Vote for this issue
                Watchers:
                1 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: