/reactive-kata

:leo: Kata as introduction to project reactor

Primary LanguageKotlin

♌ reactive kata

This kata is for use as introduction to reactive programming with kotlin and project reactor. The slides, which are a prerequisite for this dojo, are available here.

Problem Description

You have to wind up the project of your co-worker Jeff. The task is to build a dashboard for a foosball tournament. Jeff already implemented the connection to the foosball tables and a unstable poc for the dashboard user interface. The datasource is the flux from the tournament.

Exercises

  1. Summarize the games streamed by the tournament per second in a statistics object.
  2. Wire everything up by implementing the adapter to the dashboard. Note: The dashboard is very unstable and thereforce timeouts and exceptions can occour randomly.

You will get a gold star at the good noodle board if you really stream the statistics instead of .take(n) and also handle the backpressure properly.

Dataflow

Suggested operators

Summarizer

Adapter