Merge pull request #33 from marcusficner/master

Fixes changesetArrayFrom
RxSwiftCommunity · Sep 22, 2016 · f88ccfb · f88ccfb
2 parents 065dfa0 + 9b7c2e6
commit f88ccfb
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/Pod/Classes/RxRealm.swift b/Pod/Classes/RxRealm.swift
@@ -153,8 +153,9 @@ public extension ObservableType where E: NotificationEmitter {
 
      - returns: `Observable<(Array<Self.Generator.Element>, RealmChangeset?)>`
      */
-    public static func changesetArrayFrom(_ collection: E, scheduler: ImmediateSchedulerType = CurrentThreadScheduler.instance) -> Observable<(E, RealmChangeset?)> {
+    public static func changesetArrayFrom(_ collection: E, scheduler: ImmediateSchedulerType = CurrentThreadScheduler.instance) -> Observable<(Array<E.ElementType>, RealmChangeset?)> {
         return Observable.changesetFrom(collection, scheduler: scheduler)
+					.map { ($0.toArray(), $1) }
     }
 }