Skip to content

Commit 07888a9

Browse files
committed
Fixed minor at Microservices.CompositeServiceDiscovery.start0
1 parent a05b757 commit 07888a9

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

services/src/main/java/io/scalecube/services/Microservices.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -638,6 +638,7 @@ private Mono<? extends Void> start0(String id, ServiceDiscovery discovery) {
638638
disposables.add(
639639
discovery
640640
.listen()
641+
.subscribeOn(scheduler)
641642
.publishOn(scheduler)
642643
.doOnNext(event -> onDiscoveryEvent(microservices, event))
643644
.doOnNext(sink::tryEmitNext)

0 commit comments

Comments
 (0)