Examples Observers

★ = important

Do ★

#include "ReactiveArduinoLib.h"

auto observableInt = FromProperty<int>();

void setup()
{
	Serial.begin(9600);
	while (!Serial) delay(1);

	FromRange<int>(1, 10, 2)
	>> Do<int>([](int x) { Serial.println(2 * x); });
}

void loop()
{
}

DoAndFinally ★

#include "ReactiveArduinoLib.h"

auto observableInt = FromProperty<int>();

void setup()
{
	Serial.begin(9600);
	while (!Serial) delay(1);

	FromRange<int>(1, 10, 2)
	>> DoAndFinally<int>( [](int x) { Serial.println(2 * x); },
					[]() { Serial.println("No more items"); });
}

void loop()
{
}

Finally

#include "ReactiveArduinoLib.h"

auto observableInt = FromProperty<int>();

void setup()
{
	Serial.begin(9600);
	while (!Serial) delay(1);

	FromRange<int>(1, 10, 2)
	>> Finally<int>([]() { Serial.println("No more items"); });
}

void loop()
{
}

DoNothing ★

#include "ReactiveArduinoLib.h"

int values[] = { 0, 1, 1, 2, 1, 5, 4 }; 
size_t valuesLength = sizeof(values) / sizeof(values[0]);

auto observableArray = FromArray<int>(values, valuesLength);

void setup()
{
	Serial.begin(9600);
	while (!Serial) delay(1);

	observableArray
		>> If<int>([](int x) { return x > 2; }, 
				     [](int x) {Serial.println(10 * x); })
		>> If<int>([](int x) { return x <= 2; }, 
				     [](int x) {Serial.println(5 * x); })
		>> DoNothing<int>();
}

void loop()
{
}

Property

#include "ReactiveArduinoLib.h"

int myProperty;

void setup()
{
	Serial.begin(9600);
	while (!Serial) delay(1);

	FromRange<int>(1, 10, 2)
	>> ToProperty<int>(myProperty);
}

void loop()
{
}

ToArray

#include "ReactiveArduinoLib.h"

int values[] = { 0, 1, 1, 2, 1, 5, 4 };
const size_t valuesLength = sizeof(values) / sizeof(values[0]);

int finalValues[valuesLength];

void setup()
{
	Serial.begin(9600);
	while (!Serial) delay(1);

	FromArray<int>(values, valuesLength)
	>> Select<int>([](int x) {return 2 * x; })
	>> ToArray<int>(finalValues, valuesLength);

	for (size_t i = 0; i < valuesLength; i++)
		Serial.println(finalValues[i]);
}

void loop()
{
}

ToCircularBuffer

#include "ReactiveArduinoLib.h"

int values[] = { 0, 1, 1, 2, 1, 5, 4 };
const size_t valuesLength = sizeof(values) / sizeof(values[0]);

const size_t finalValuesLength = 5;
int finalValues[finalValuesLength];

void setup()
{
	Serial.begin(9600);
	while (!Serial) delay(1);

	FromArray<int>(values, valuesLength)
	>> Select<int>([](int x) {return 2 * x; })
	>> ToCircularBuffer<int>(finalValues, finalValuesLength);

	for (size_t i = 0; i < finalValuesLength; i++)
		Serial.println(finalValues[i]);
}

void loop()
{
}

ToDigitalOutput

#include "ReactiveArduinoLib.h"

auto observableInt = FromProperty<int>();

void setup()
{
	Serial.begin(9600);
	while (!Serial) delay(1);

	observableInt
	>> Select<int>([](int x) {return x >=3 ? HIGH : LOW; })
	>> ToDigitalOutput<int>(10);
}

void loop()
{
	delay(1000);
	observableInt = 1;
	delay(1000);
	observableInt = 5;
	delay(1000);
	observableInt = 2;
	delay(1000);
	observableInt = 3;
}

ToAnalogOutput

#include "ReactiveArduinoLib.h"

auto observableInt = FromProperty<int>();

void setup()
{
	Serial.begin(9600);
	while (!Serial) delay(1);

	observableInt
	>> Select<int>([](int x) {return x * 50; })
	>> ToAnalogOutput<int>(11);
}

void loop()
{
	delay(1000);
	observableInt = 1;
	delay(1000);
	observableInt = 5;
	delay(1000);
	observableInt = 2;
	delay(1000);
	observableInt = 3;
}

ToSerial

#include "ReactiveArduinoLib.h"

int values[] = { 0, 1, 1, 2, 1, 5, 4 };
const size_t valuesLength = sizeof(values) / sizeof(values[0]);

void setup()
{
	Serial.begin(9600);
	while (!Serial) delay(1);

	FromArray<int>(values, valuesLength)
	>> ToSerial<int>();
}

void loop()
{
}