small fix

This commit is contained in:
Ivan Smolin 2017-02-08 09:00:30 +03:00
parent c537a7f5ca
commit bee3791ef5
1 changed files with 2 additions and 2 deletions

View File

@ -157,7 +157,7 @@ public extension Reactive where Base: UserDefaults {
///
/// - returns: Observable of specified model type.
func object<T>(forKey key: String, defaultValue: T) -> Observable<T> where T: ImmutableMappable {
return Observable.just(self.base.object(forKey: key, defaultValue: defaultValue))
return Observable.deferredJust { self.base.object(forKey: key, defaultValue: defaultValue) }
}
/// Reactive version of object<T>(forKey:) -> [T].
@ -179,7 +179,7 @@ public extension Reactive where Base: UserDefaults {
///
/// - returns: Observable of specified array type.
func object<T>(forKey key: String, defaultValue: [T]) -> Observable<[T]> where T: ImmutableMappable {
return Observable.just(self.base.object(forKey: key, defaultValue: defaultValue))
return Observable.deferredJust { self.base.object(forKey: key, defaultValue: defaultValue) }
}
/// Reactive version of set<T>(_:forKey:).