Observers

Observer Do

Performs an action on each emitted item

Do(ReactiveAction<T> action)

Observer Finally

Performs an action at the end of the sequence

Finally(ReactiveCallback action)

Observer DoAndFinally

Performs an action on each emmited item, and another action at the end of the sequence

DoAndFinally(ReactiveAction<T> doAction, ReactiveCallback finallyAction)

Observer DoNothing

Suscribes to and observable but do nothing with the received items.

Usefull when you use ForEach or If operators, but no really interested in a Observer

DoAndFinally(ReactiveAction<T> doAction, ReactiveCallback finallyAction)

Observer Property

Stores the sequence items in a variable

ToProperty(T & property)

Observer Array

Stores the items emitted in an existing array

ToArray(T *array, size_t length)

Observer CircularBuffer

Stores the items emitted in an existing array, treated as a circular buffer

ToCircularBuffer(T *array, size_t length)

Observer Digital Pin

Sends the sequence items to an digital pin

ToDigital(uint8_t pin)

Observer Analog Pin

Sends the sequence items to an analog pin

ToAnalog(uint8_t pin)

Observer Serial

Sends the sequence items to the serial port

ToSerial()