From 9b7c2e633cdeead4e537ea62957720e7dc850eb2 Mon Sep 17 00:00:00 2001 From: Marcus Ficner Date: Thu, 22 Sep 2016 22:48:00 +0200 Subject: [PATCH] Fixes changesetArrayFrom --- Pod/Classes/RxRealm.swift | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/Pod/Classes/RxRealm.swift b/Pod/Classes/RxRealm.swift index 8bacf33..7e789bb 100644 --- a/Pod/Classes/RxRealm.swift +++ b/Pod/Classes/RxRealm.swift @@ -153,8 +153,9 @@ public extension ObservableType where E: NotificationEmitter { - returns: `Observable<(Array, 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, RealmChangeset?)> { return Observable.changesetFrom(collection, scheduler: scheduler) + .map { ($0.toArray(), $1) } } }