Hiding clunky implementation details within neat CONNECT API.

aentinger · aentinger · commit 5e676132b79e · 2021-12-06T15:19:02.000+01:00
diff --git a/examples/Threading_Basics/Source_Sink_Counter/Source_Sink_Counter.ino b/examples/Threading_Basics/Source_Sink_Counter/Source_Sink_Counter.ino
@@ -5,7 +5,7 @@
 
 void setup()
 {
-  ProducerPrivate::counter.connectTo(ConsumerPrivate::counter);
+  CONNECT(Producer, counter, Consumer, counter);
   Producer.start();
   Consumer.start();
 }
diff --git a/examples/Threading_Basics/Source_Sink_LED/Source_Sink_LED.ino b/examples/Threading_Basics/Source_Sink_LED/Source_Sink_LED.ino
@@ -5,7 +5,7 @@
 
 void setup()
 {
-  Source_ThreadPrivate::led.connectTo(Sink_ThreadPrivate::led);
+  CONNECT(Source_Thread, led, Sink_Thread, led);
   Sink_Thread.start();
   Source_Thread.start();
 }
diff --git a/src/Arduino_Threads.h b/src/Arduino_Threads.h
@@ -74,6 +74,9 @@ SinkBlocking<type> name{size}
 #define SINK_NON_BLOCKING(name, type) \
 SinkNonBlocking<type> name{}
 
+#define CONNECT(source_thread, source_name, sink_thread, sink_name) \
+source_thread##Private::source_name.connectTo(sink_thread##Private::sink_name)
+
 #define SHARED(name, type) \
   Shared<type> name
 

Original file line number	Diff line number	Diff line change
`@@ -5,7 +5,7 @@`
`5`	`5`
`6`	`6`	`void setup()`
`7`	`7`	`{`
`8`		`- ProducerPrivate::counter.connectTo(ConsumerPrivate::counter);`
	`8`	`+ CONNECT(Producer, counter, Consumer, counter);`
`9`	`9`	`Producer.start();`
`10`	`10`	`Consumer.start();`
`11`	`11`	`}`
Original file line number	Diff line number	Diff line change
`@@ -5,7 +5,7 @@`
`5`	`5`
`6`	`6`	`void setup()`
`7`	`7`	`{`
`8`		`- Source_ThreadPrivate::led.connectTo(Sink_ThreadPrivate::led);`
	`8`	`+ CONNECT(Source_Thread, led, Sink_Thread, led);`
`9`	`9`	`Sink_Thread.start();`
`10`	`10`	`Source_Thread.start();`
`11`	`11`	`}`