From b55f16b1fc9da432b41dc5275d5513679e266d79 Mon Sep 17 00:00:00 2001 From: Zuo Les <44486110+StackInk@users.noreply.github.com> Date: Mon, 13 Jan 2025 10:47:51 +0800 Subject: [PATCH] Update schedulers.adoc --- docs/modules/ROOT/pages/coreFeatures/schedulers.adoc | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/docs/modules/ROOT/pages/coreFeatures/schedulers.adoc b/docs/modules/ROOT/pages/coreFeatures/schedulers.adoc index 678775aaaf..658e58d6a1 100644 --- a/docs/modules/ROOT/pages/coreFeatures/schedulers.adoc +++ b/docs/modules/ROOT/pages/coreFeatures/schedulers.adoc @@ -155,7 +155,7 @@ final Flux flux = Flux .publishOn(s) //<3> .map(i -> "value " + i); //<4> -new Thread(() -> flux.subscribe(System.out::println)); //<5> +new Thread(() -> flux.subscribe(System.out::println)).start(); //<5> ---- <1> Creates a new `Scheduler` backed by four `Thread` instances. <2> The first `map` runs on the anonymous thread in <5>. @@ -196,7 +196,7 @@ final Flux flux = Flux .subscribeOn(s) //<3> .map(i -> "value " + i); //<4> -new Thread(() -> flux.subscribe(System.out::println)); //<5> +new Thread(() -> flux.subscribe(System.out::println)).start(); //<5> ---- <1> Creates a new `Scheduler` backed by four `Thread`. <2> The first `map` runs on one of these four threads...