ScatteredStreamIteratorTest random failure

      java.lang.NullPointerException
	at org.infinispan.remoting.transport.jgroups.JGroupsTransport.invokeCommand(JGroupsTransport.java:877)
	at org.infinispan.remoting.rpc.RpcManagerImpl.invokeCommand(RpcManagerImpl.java:146)
	at org.infinispan.reactive.publisher.impl.ClusterPublisherManagerImpl$SubscriberHandler.sendCancelCommand(ClusterPublisherManagerImpl.java:1077)
	at org.infinispan.reactive.publisher.impl.InnerPublisherSubscription.run(InnerPublisherSubscription.java:93)
	at io.reactivex.rxjava3.internal.operators.flowable.FlowableDoOnLifecycle$SubscriptionLambdaSubscriber.cancel(FlowableDoOnLifecycle.java:115)
	at io.reactivex.rxjava3.internal.subscriptions.SubscriptionArbiter.drainLoop(SubscriptionArbiter.java:221)
	at io.reactivex.rxjava3.internal.subscriptions.SubscriptionArbiter.drain(SubscriptionArbiter.java:190)
	at io.reactivex.rxjava3.internal.subscriptions.SubscriptionArbiter.cancel(SubscriptionArbiter.java:182)
	at io.reactivex.rxjava3.internal.subscriptions.SubscriptionArbiter.drainLoop(SubscriptionArbiter.java:221)
	at io.reactivex.rxjava3.internal.subscriptions.SubscriptionArbiter.drain(SubscriptionArbiter.java:190)
	at io.reactivex.rxjava3.internal.subscriptions.SubscriptionArbiter.cancel(SubscriptionArbiter.java:182)
	at io.reactivex.rxjava3.internal.subscriptions.SubscriptionHelper.cancel(SubscriptionHelper.java:181)
	at io.reactivex.rxjava3.internal.operators.flowable.BlockingFlowableIterable$BlockingFlowableIterator.run(BlockingFlowableIterable.java:173)
	at io.reactivex.rxjava3.internal.operators.flowable.BlockingFlowableIterable$BlockingFlowableIterator.hasNext(BlockingFlowableIterable.java:104)
	at org.infinispan.commons.util.Closeables$1.hasNext(Closeables.java:247)
	at org.infinispan.stream.DistributedStreamIteratorTest.lambda$verifyNodeLeavesBeforeGettingData$0(DistributedStreamIteratorTest.java:136)
	at org.infinispan.test.AbstractInfinispanTest$CallableWrapper.call(AbstractInfinispanTest.java:527)
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
	at java.base/java.lang.Thread.run(Thread.java:834)