Operators

First

Emits the first item in a sequence, when the sequence is complete.

First()

To emit as soon as recieved use TakeFirst()

Last

Emits the last item in a sequence, when the sequence is complete.

First()

To emit as soon as recieved use TakeLast()

Last()

Distinct

Emits the item recieved if is not equal to the last item recieved.

Distinct() 

Where

Emit the item recieved if it satisfy a condition

Where(ReactiveCondition<T> condition)

Select

Emit the item recieved transformed by a function

Select(ReactiveFunction<T> function)

ForEach

Performs an action each time it recieved an item

ForEach(ReactiveAction<T> function)

If

Performs an action each time if the item recieved satisfy a condition

If(ReactiveCondition<T> condition, ReactiveAction<T> function)

Cast

Cast the recieved item

Cast()

Map

Emit the item recieved transformed by a function to another type of data

Map(ReactiveMap<Torig, Tdest> map)

Toggle

Emits an state that toggles each time an item is recieved

Toggle(bool state = false)

Skip

Skips N items recieved

Skip(size_t num)

SkipUntil

Skips until recieved item satisfy a condition

SkipUntil(ReactiveCondition<T> condition)

SkipWhile

Skips while recieved item satisfy a condition

SkipWhile(ReactiveCondition<T> condition)

Take

Emits the N first items recieved

Take(size_t num)

TakeAt

Emits the N item recieved

TakeAt(size_t index)

TakeFirst

Emits the first item recieved

TakeFirst()

TakeLast

Emits the last item recieved

TakeLast()

TakeUntil

Emits until recieved item satisfy a condition

TakeUntil(ReactiveCondition<T> condition)

TakeWhile

Emits while recieved item satisfy a condition

TakeWhile(ReactiveCondition<T> condition)

Millis

Emits millis when a item is recieved

Millis()

Micros

Emits micros when a item is recieved

Micros()

ElapsedMillis

Emits millis elapsed from the last item is recieved

ElapsedMillis()

ElapsedMicros

Emits micros elapsed from the last item is recieved

ElapsedMicros()

Repeat

Repeat a sequence N times

Repeat(size_t N)

Loop

Loops a sequence forever

Loop()

NotReset

Breaks the reset signal upwards

NotReset()

Split

Split an string using a separator

Split(char separator = ',')

Buffer

WIP

Buffer()

Join

Join recieved items using a separator

Join(char separator = ',')

ParseInt

Parse the recieved item to Int

ParseInt()

ParseFloat

Parse the recieved item to Float

ParseFloat()