* recreate the realm each time

RxSwiftCommunity · Jun 13, 2016 · 82899fc · 82899fc
1 parent b471e34
commit 82899fc
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/Pod/Classes/RealmObserver.swift b/Pod/Classes/RealmObserver.swift
@@ -38,7 +38,9 @@ class RealmObserver<E>: ObserverType {
         case .Next(let element):
             //this will "cache" the realm on this thread, until completed/errored
             if let configuration = configuration where realm == nil {
-                realm = try! Realm(configuration: configuration)
+                let realm = try! Realm(configuration: configuration)
+                binding(realm, element)
+                return;
             }
 
             guard let realm = realm else {