Propogate boolean in Headstage64 stimulator triggers

- These operators were not acting as sinks because they were not propogating their observable sequence - Fixes #83
open-ephys · Aug 15, 2024 · 3305365 · 3305365
1 parent 7ac700f
commit 3305365
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 2 deletions.
diff --git a/OpenEphys.Onix1/Headstage64ElectricalStimulatorTrigger.cs b/OpenEphys.Onix1/Headstage64ElectricalStimulatorTrigger.cs
@@ -208,7 +208,11 @@ public override IObservable<bool> Process(IObservable<bool> source)
                 {
                     var device = deviceInfo.GetDeviceContext(typeof(Headstage64ElectricalStimulator));
                     var triggerObserver = Observer.Create<bool>(
-                        value => device.WriteRegister(Headstage64ElectricalStimulator.TRIGGER, value ? 1u : 0u),
+                        value =>
+                        {
+                            device.WriteRegister(Headstage64ElectricalStimulator.TRIGGER, value ? 1u : 0u);
+                            observer.OnNext(value);
+                        },
                         observer.OnError,
                         observer.OnCompleted);
 

diff --git a/OpenEphys.Onix1/Headstage64OpticalStimulatorTrigger.cs b/OpenEphys.Onix1/Headstage64OpticalStimulatorTrigger.cs
@@ -202,7 +202,11 @@ public override IObservable<bool> Process(IObservable<bool> source)
                 {
                     var device = deviceInfo.GetDeviceContext(typeof(Headstage64OpticalStimulator));
                     var triggerObserver = Observer.Create<bool>(
-                        value => device.WriteRegister(Headstage64OpticalStimulator.TRIGGER, value ? 1u : 0u),
+                        value =>
+                        {
+                            device.WriteRegister(Headstage64OpticalStimulator.TRIGGER, value ? 1u : 0u);
+                            observer.OnNext(value);
+                        },
                         observer.OnError,
                         observer.OnCompleted);