Medium Hot vs Cold Publishers

Replay with Cache

Traducción al español en progresoEl contenido detallado de esta lección aún se está traduciendo. Mientras tanto, se muestra en inglés.

Create a Flux emitting "A", "B", "C" and use .cache() to replay all elements to late subscribers. Subscribe twice and verify both get all values.

cache() replays previously emitted elements to new subscribers.

Esperado

Sub1: A
Sub1: B
Sub1: C
Sub2: A
Sub2: B
Sub2: C

Anterior Siguiente

Main.kt

Replay with Cache

medium⏱ 15 minkotlinreactorchallengehot-cold

Create a Flux emitting "A", "B", "C" and use .cache() to replay all elements to late subscribers. Subscribe twice and verify both get all values.

cache() replays previously emitted elements to new subscribers.

Why this works

cache() turns a Flux into a hot publisher that replays all cached elements to new subscribers. Unlike share(), which may cause late subscribers to miss items, cache() ensures everyone gets the full history.

Expected output

Sub1: A
Sub1: B
Sub1: C
Sub2: A
Sub2: B
Sub2: C

Replay with Cache

Traducción al español en progresoEl contenido detallado de esta lección aún se está traduciendo. Mientras tanto, se muestra en inglés.

Create a Flux emitting "A", "B", "C" and use .cache() to replay all elements to late subscribers. Subscribe twice and verify both get all values.

cache() replays previously emitted elements to new subscribers.

Esperado

Sub1: A Sub1: B Sub1: C Sub2: A Sub2: B Sub2: C

Replay with Cache

medium⏱ 15 minkotlinreactorchallengehot-cold

Create a Flux emitting "A", "B", "C" and use .cache() to replay all elements to late subscribers. Subscribe twice and verify both get all values.

cache() replays previously emitted elements to new subscribers.

Why this works

Expected output

Sub1: A Sub1: B Sub1: C Sub2: A Sub2: B Sub2: C