Copied the code from OperationMerge
Properly wired up SynchronizedObserver within MergeDelayError operator