-
Notifications
You must be signed in to change notification settings - Fork 8
Transformations
Emit received items transformed by a function
Select(ReactiveFunction<T> function)
Cast received item to another type
Cast()
Emit received items transformed by a function to another type
Map(ReactiveMap<Torig, Tdest> map)
Apply a function to each item emitted by an Observable, sequentially
Reduce(ReactiveCompound<T> function)
Emits received item cropped by a lower and upper limit
Limit(T lowerLimit, T upperLimit)
Emits received item cropped by an upper limit
LimitUpper(T upperLimit)
Emits received item cropped by a lower limit
LimitLower(T lowerLimit)
Emits received items scaled (interpolated) to a different range
Scale(T input_min, T input_max, T output_min, T output_max)
Emits timestamp when a item is received
Millis version
Millis()
Micros version
Micros()
Emits time elapsed since last item is received
Millis version
ElapsedMillis()
Micros version
ElapsedMicros()
Emits an state that toggles each time an item is received
Toggle(bool state = false)
Emits an state which varies when the value received goes above or below a certain Threshold
Threshold(T threshold)
Threshold(T threshold, bool initialState)
Threshold(T lowThreshold, T highThreshold)
Threshold(T lowThreshold, T highThreshold, bool initialState)
Emits an state that toggles each time an item is received
TransformationAdcToVoltage<T>& AdcToVoltage(T input_max = 1023, T output_max = 5.0)
Split an string using a separator
Split(char separator = ',')
Emits and String that contatenates all received items
Buffer()
Join received items using a separator
Join(char separator = ',')
Emits true if received item is not equal zero
ParseInt()
Emits received items parsed to Int
ParseInt()
Emits received items parsed to Float
ParseFloat()