swift-developers-japan
開発環境, ライブラリ / rx
Rx, RAC
on オペレーターではterminatedとdisposedは分離されてます https://github.com/ReactiveCocoa/ReactiveSwift/blob/bb2a2d6f422f79ebc86a755642ca9bd106578d12/Sources/Signal.swift#L886-L924 
3
3
/** Abstracts work that needs to be performed on `MainThread`. In case `schedule` methods are called from main thread, it will perform action immediately without scheduling. This scheduler is optimized for `subscribeOn` operator. If you want to observe observable sequence elements on main thread using `observeOn` operator, `MainScheduler` is more suitable for that purpose. */ 
guard let self = self { でいいんじゃないでしょか。
1
self?.navigationController はオプショナルチェインで(.?.?)書いちゃうかな。 1 
.filterNil() ( Observable<Optional<T>> -> Observable<T> ) みたいなのも探していたのですが、それは RxCommunity のRxOptionalにありました。 
must_have_weak_cupture_argument_in_subscribe: name: Must have weak capture argument in Rx#subscribe method match_kinds: - keyword - identifier - typeidentifier - attribute.builtin included: "./(Folio|Redux)/.*\\.swift" regex: rx.tap\s\s*.subscribe\(onNext:\s\{\s(?!\[weak) message: Must have weak capture argument in Rx#subscribe method severity: error ^ これはsubscribeの中はweakキャプチャしなければならない、というルールですが、こんな感じで追加したらいいと思います。
3
1
return Observable<[Elements]>.create { observer in let realmElements = realm.objects(Elements.self) observer.onNext(Array(realmElements)) let token = realmElements .observe { result in switch result { case .update(let data, _, _, _): observer.onNext(Array(data)) case .error(let error): observer.onError(error) default: break } } return Disposables.create { token.invalidate() } }
return Observable<[Elements]>.create { observer in observer.onNext(Array(realm.objects(Elements.self))) let token = realm.objects(Elements.self) .observe { result in switch result { case .update(let data, _, _, _): observer.onNext(Array(data)) case .error(let error): observer.onError(error) default: break } } return Disposables.create { token.invalidate() } } どちらも onNext はちゃんと流れるけど、上だとnextで流れる内容がバグっていることがある、なんでだ (Rx + Realm のはなし 
