Removes special debug behavior regarding reentrancy.

NoTests · Aug 31, 2017 · 094c7a1 · 094c7a1
1 parent 64a5476
commit 094c7a1
Showing 1 changed file with 4 additions and 8 deletions.
diff --git a/Sources/RxFeedback/ObservableType+RxFeedback.swift b/Sources/RxFeedback/ObservableType+RxFeedback.swift
@@ -67,14 +67,10 @@ extension ObservableType where E == Any {
             let events: Observable<Event> = Observable.merge(scheduledFeedback.map { feedback in
                 let state = ObservableSchedulerContext(source: replaySubject.asObservable(), scheduler: asyncScheduler)
                 let events = feedback(state)
-                #if DEBUG
-                    return events
-                #else
-                    return events
-                        // This is protection from accidental ignoring of scheduler so
-                        // reentracy errors can be avoided
-                        .observeOn(CurrentThreadScheduler.instance)
-                #endif
+                return events
+                    // This is protection from accidental ignoring of scheduler so
+                    // reentracy errors can be avoided
+                    .observeOn(CurrentThreadScheduler.instance)
             })
 
             return events.scan(initialState, accumulator: reduce)