|
Change Return Type void to CompletableFuture<Void> in method public addSubscriber(subject MessageSubject, decoder Function<byte[],M>, handler Function<M,R>, encoder Function<R,byte[]>, executor Executor) : CompletableFuture<Void> in class io.atomix.messaging.ClusterCommunicationService |
From |
To |
|
Change Return Type void to CompletableFuture<Void> in method public addSubscriber(subject MessageSubject, decoder Function<byte[],M>, handler Consumer<M>, executor Executor) : CompletableFuture<Void> in class io.atomix.messaging.ClusterCommunicationService |
From |
To |
|
Change Return Type void to CompletableFuture<Void> in method public addSubscriber(subject MessageSubject, decoder Function<byte[],M>, handler Function<M,CompletableFuture<R>>, encoder Function<R,byte[]>) : CompletableFuture<Void> in class io.atomix.messaging.ClusterCommunicationService |
From |
To |