Signals Explained

Signals

Signals provide a way to access the changes within a stream e.g.

 Stream.of(1,1,1,1,1,1,1,1,1,1,2)

Should result in a Stream

 Stream.of(1,2)

A Signal can be backed by either a Queue or a Topic (and the rules as to whether all messages will be seen by Processing Stream A or B will depend on which is used).

Signal signal = Signal.queueBackedSignal();

//thread 1 : populate signal with health data signal.fromStream(Stream.generate(()->checkHealthStatus())
                        .peek(status -> sleep(500));

//thread 2 : read changes in health from Signal
signal.stream().forEach(health -> respond(health));