ConnectableFlux with AutoConnect

Create a Flux of "X", "Y", "Z". Use .publish() to make it connectable, then .autoConnect(2) to auto-start when 2 subscribers are connected. Subscribe twice and print with prefixes.

autoConnect(n) waits for n subscribers before starting emission.

Expected

Sub1: X
Sub2: X
Sub1: Y
Sub2: Y
Sub1: Z
Sub2: Z

Previous Next

Main.kt

ConnectableFlux with AutoConnect

hard⏱ 15 minkotlinreactorchallengehot-cold

Create a Flux of "X", "Y", "Z". Use .publish() to make it connectable, then .autoConnect(2) to auto-start when 2 subscribers are connected. Subscribe twice and print with prefixes.

autoConnect(n) waits for n subscribers before starting emission.

Why this works

publish() converts a Flux into a ConnectableFlux. autoConnect(n) automatically connects (starts emitting) when n subscribers have subscribed. This ensures all subscribers are ready before data flows.

Expected output

Sub1: X
Sub2: X
Sub1: Y
Sub2: Y
Sub1: Z
Sub2: Z

ConnectableFlux with AutoConnect

Create a Flux of "X", "Y", "Z". Use .publish() to make it connectable, then .autoConnect(2) to auto-start when 2 subscribers are connected. Subscribe twice and print with prefixes.

autoConnect(n) waits for n subscribers before starting emission.

Expected

Sub1: X Sub2: X Sub1: Y Sub2: Y Sub1: Z Sub2: Z

ConnectableFlux with AutoConnect

hard⏱ 15 minkotlinreactorchallengehot-cold

Create a Flux of "X", "Y", "Z". Use .publish() to make it connectable, then .autoConnect(2) to auto-start when 2 subscribers are connected. Subscribe twice and print with prefixes.

autoConnect(n) waits for n subscribers before starting emission.

Why this works

publish() converts a Flux into a ConnectableFlux. autoConnect(n) automatically connects (starts emitting) when n subscribers have subscribed. This ensures all subscribers are ready before data flows.

Expected output

Sub1: X Sub2: X Sub1: Y Sub2: Y Sub1: Z Sub2: Z