diff --git a/OpenEphys.Onix1/Headstage64ElectricalStimulatorTrigger.cs b/OpenEphys.Onix1/Headstage64ElectricalStimulatorTrigger.cs index e0cd689..879f6d2 100644 --- a/OpenEphys.Onix1/Headstage64ElectricalStimulatorTrigger.cs +++ b/OpenEphys.Onix1/Headstage64ElectricalStimulatorTrigger.cs @@ -208,7 +208,11 @@ public override IObservable Process(IObservable source) { var device = deviceInfo.GetDeviceContext(typeof(Headstage64ElectricalStimulator)); var triggerObserver = Observer.Create( - 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 index 34f6f06..88a796e 100644 --- a/OpenEphys.Onix1/Headstage64OpticalStimulatorTrigger.cs +++ b/OpenEphys.Onix1/Headstage64OpticalStimulatorTrigger.cs @@ -202,7 +202,11 @@ public override IObservable Process(IObservable source) { var device = deviceInfo.GetDeviceContext(typeof(Headstage64OpticalStimulator)); var triggerObserver = Observer.Create( - value => device.WriteRegister(Headstage64OpticalStimulator.TRIGGER, value ? 1u : 0u), + value => + { + device.WriteRegister(Headstage64OpticalStimulator.TRIGGER, value ? 1u : 0u); + observer.OnNext(value); + }, observer.OnError, observer.OnCompleted);