A big rework of the source/sink system.

Author: aentinger

examples/Demo_Shared/Consumer.inot renamed to examples/Demo_Shared_Counter/Consumer.inot

@@ -1,11 +1,13 @@
-void setup() {
+void setup()
+{
   Serial.begin(115200);
   while (!Serial) { }
 
   Producer.start();
   Consumer.start();
 }
 
-void loop() {
+void loop()
+{
   rtos::ThisThread::yield();
 }

examples/Demo_Shared/Demo_Shared.ino renamed to examples/Demo_Shared_Counter/Demo_Shared_Counter.ino

@@ -0,0 +1,11 @@
+SINK(counter, int);
+
+void setup()
+{
+
+}
+
+void loop()
+{
+  Serial.println(counter.read());
+}

examples/Demo_Shared/Producer.inot renamed to examples/Demo_Shared_Counter/Producer.inot

@@ -0,0 +1,16 @@
+/*
+ * This examples demonstrates the SOURCE/SINK abstraction.
+ * Each thread may have any number of SOURCES and SINKS that can be connected
+ * together using the "connectTo" method.
+ */
+
+void setup()
+{
+  Producer.counter.connectTo(Consumer.counter);
+  Producer.start();
+  Consumer.start();
+}
+
+void loop() {
+  rtos::ThisThread::yield();
+}

examples/Demo_Shared/SharedVariables.h renamed to examples/Demo_Shared_Counter/SharedVariables.h

@@ -0,0 +1,13 @@
+SOURCE(counter, int);
+
+void setup()
+{
+
+}
+
+void loop()
+{
+  static int i = 0;
+  counter.write(i);
+  i++;
+}