May 7, 2016 TestScheduler RxSwiftにはVirtualTimeSchedulerというSchedulerがあって、仮想的な時間でイベントストリームを扱えます。仮想的な時間というとなんだか難しそうですが、要は時間を自分で操作できるSchedulerということです。 RxSwiftのテストライブラリのRxTestsには、TestSchedulerというSchedulerも用意されています。これはVirtualTimeSchedulerにテスト向けの機能をつけたもので、イベントを記録できたりします。記録したイベントはXCTAssertEqual(_:_:)で検証できるので、どの時刻にどの値が来くるかテストできるというわけです。 func test() { let scheduler = TestScheduler(initialClock: 0) let obser

最近はRxSwiftにどっぷりハマっているのですが、いまいちconcatとmergeの違いが掴めてなかったので、 再度調べたりサンプルコードを書きながら整理してみました。 まずは2つのマーブル図を見てみる 整理するために、ReactiveX公式のマーブル図を見てみます。 concat merge 図をみると、どちらも2つのものを合成する関数ですが、 mergeとconcatの違いはmergeはObservableを合成する際に全てのストリームの順を考慮して合成のに対し、concatは引数で渡されたObservableの順で合成すること。 (参考: 非同期や並列処理にも役立つRxJavaの使い方) という違いがあるようです。 mergeはストリームの流れを見て、うまく合成して順番を決めますが、 concatは最初に合成した時点での順番に依存するようですね。 実際に動かしてみる 以上をふまえて

すっごい簡単なものですが、 viewWillAppear: が呼ばれたのをトリガーにするObservableを定義してみました。 これで、 viewWillAppear がcallされた時をトリガーにして、リロード処理をする等できます。 定義してみる 内容はとても簡単で、extensionでNSObjectに対して実装されている、 _rxsentMessage(:)_ を使ってあげるだけです。 引数にselectorを渡してあげることで、その関数が呼ばれた時を捕捉することができます。 import Foundation import UIKit import RxSwift extension UIViewController { private func trigger(selector: Selector) -> Observable<Void> { return rx_sentMes

atte FeS【Go・Swift開発編】での発表資料に加筆・修正をしたものです。 http://mercari.connpass.com/event/29506/

RxSwift勉強会

4月14日 RxSwift勉強会の発表資料です！

RxSwift勉強会 ＠ Sansanの発表資料です http://connpass.com/event/27933/

RxSwift勉強会発表資料です http://connpass.com/event/27933/

struct Timeline { let name: String let profileImage: UIImage let bodyContent: String } override func viewDidLoad() { super.viewDidLoad() let elements = Driver.just([ Timeline(name: "yuzushioh", profileImage: UIImage(named: "")!, bodyContent: ""), Timeline(name: "yuzushioh", profileImage: UIImage(named: "")!, bodyContent: ""), Timeline(name: "yuzushioh", profileImage: UIImage(named: "")!, bodyConte

RxSwiftは，RxプログラミングモデルをSwiftに移植することを目的としたプロジェクトで，その抽象化を可能な限り取り入れている。メンテナのKrunoslav Zaher氏に話を聞いた。 RxSwiftでは，Observable<Element>をベースとすることによって，非同期処理やイベントストリームを容易に構成することができる。Observerは，RxSwiftではシーケンスと等価であるため，データやイベントのストリームなどのシーケンスの要素に対する高レベルな操作を，Observableインターフェースのオペレーションを通じてモデル化することが可能だ。 RxSwiftのフレキシブルなプログラミングモデルは，UIを含むバインディングやリトライ，デリゲート，KVO, 通知など，さまざまなユースケースに対応する。 次のプログラム例は，rx_text演算子を使用して２つのテキストフィールド

RxSwiftでは、処理をどのスレッドで実行するか指定するSchedulerが用意されていて、 このSchedulerをセットすることで、それぞれの処理に対して実行するスレッドを指定できます。 その時のSchedulerの作り方と、Schedulerを使う時にお行儀よく扱うための備忘録兼ねたメモです。 (本当にメモ程度に書いてるので所々表現おかしかったりするかもです。ゴメンナサイ…) それぞれのScheduler メインスレッドで実行するScheduler let mainScheduler = MainScheduler.instance MainScheduler.instanceを呼び出してあげれば良いようです。 このMainSchedulerは シングルトン になっているので、都度作られることはないようです。 中身を除いてみると、処理を内部で実行スレッドをチェックしたあと、必要があ

元ネタ Javaの講義、試験が「自作関数を作り記述しなさい」って問題だったから 「ズン」「ドコ」のいずれかをランダムで出力し続けて「ズン」「ズン」「ズン」「ズン」「ドコ」の配列が出たら「キ・ヨ・シ！」って出力した後終了って関数作ったら満点で単位貰ってた — てくも (@kumiromilk) March 9, 2016 RxSwiftで書いてみた ズンかドコが延々と流れてくるズンドコ川を作って、scanで直近5件の配列を作り、[ズン,ズン,ズン,ズン,ドコ]になるまでtakeWhileしたらできました。RxSwift 2.2.0で動きます。 import RxSwift import Foundation enum ズンドコ: UInt32 { case ズン case ドコ } let ズンドコ川 = Observable<Int>.interval(0.5, scheduler: Ma

RxSwiftをちょっとずつ読んでる。最初はちょっと継承構造が激しい印象を受けたけど、基本的に関数型のワードに疎い自分でもとても読みやすいです。 Rxの不思議を理解していくと、アプリケーション内の別のパラダイムと仲良くする方法を考えるときのヒントになったり、まだ見ぬ応用が待っている予感がします。 ObservableとSink Rxは、関数型言語の知識や並行処理の知識がなくても普通に使えるため、まずはその辺の事柄に目をつむり、 Observable がどう作用しているか理解するところから見ていきます。 さて、 Observable のオペレーターメソッドはなにをしているんでしょうか。 Observable に生えている map やら flatMap やらの各オペレーターメソッドは、新しいObservableを作って返しますが、このとき返るのはもちろん、オペレーターごとの挙動がカスタマイズさ

FunctionalReactiveProgramming(FRP)の勉強中です。 まだ正直なところ『なるほど，分からん』という状態ですが RxSwiftをおっかなびっくり触ってみた結果を整理しようと思います。 (触ってみたら動いたレベルなので他に良い使い方があるかも......です) 1. RxSwiftとは？ ReactiveX(Reactive Extension)という，FRPを実現するためのライブラリのSwift実装です。 Swift実装以外にもJavaScriptやJava，C#など様々な言語で実装されたライブラリがあるようです。 (AndroidだとRxAndroidとかあるみたいですね) RxSwift 2. どんなことが出来るの？ 分かりやすいポイント(というか自分が現状で理解できた範囲では) 「データバインド」と「Promiseパターン」を簡単に実現できるようになります

今日からRxSwiftはじめる方へ。 最初の導入 概念理解 まずはstream(observable)の理解 【翻訳】あなたが求めていたリアクティブプログラミング入門 Cold,Hotについて http://qiita.com/toRisouP/items/f6088963037bfda658d3 コードを触る RxSwift https://github.com/ReactiveX/RxSwift まずはplaygroundを触りながら理解。 playgroundの日本語訳がこちらにまとめられているのであわせて。 http://tiny-wing.hatenablog.com/entry/2016/01/02/161322 オススメサンプル ./RxExampleの中にいい感じのサンプルが入ってるので探す。 githubのapiとページング GitHubSearchRepositorie

RxSwiftを触り始めて2週間ほど経ちました。 近頃はObservable型を使った複数処理の連結実行が便利！？と感じています。 上手く使えば、処理同士を疎結合に保ちながら連結実行できるようになり、 保守性向上に大きく寄与しそうです。 今回は、その辺りを少し整理して書いてみたいと思います。 (例によって試したら動いた！レベルなので他の良い方法があるかも......です) 1. この記事で解決したい課題 まず、今回の記事で解決したい課題を書いてみます。 「指定したURLにリクエストを投げて、返却されたHTMLデータをファイル保存する」 という処理をRxSwiftのObservable型を使って綺麗に実装することを考えます。 この処理を実装しようとした場合、まず以下の2つの処理を分けて実装し、 それらを組み合わせる方式で実現しようとするのではないでしょうか？ 引数で渡されたURLにリクエスト

はじめに 以前触ったことがあったObjective-C製のReactiveなライブラリとしてReactiveCocoa(RAC)がありますがObjective-Cで書かれてることもあって、マクロごりごりで組まれていてSwiftで書くとあまり書きやすいイメージがありませんでした。 なので今回は、よりSwiftの世界に歩み寄ったReactiveなライブラリということでRxSwiftを体験してみました。 そもそもRxSwiftとは？ RxSwiftとはReactiveX (Reactive Extensions)のSwift実装のライブラリで、よく名前を耳にするReactiveProgramming(RP)をSwiftの世界で実現してくれるものです。 ReactiveXはSwiftだけでなく様々なプログラミング言語でライブラリが存在しており、他のプラットフォームでもその概念を持ち込むことが可能で

とりあえずRxSwiftのプレイグラウンドのIntroductionに書いてあるサンプルを見ていく。Introductionには「RxSwiftを理解する鍵は、Observablesの概念を理解することである」と書いてあるとおり、主にObservableの生成について説明してある。 環境 Xcode 7.2 Swift 2.1.1 準備 GitHubからReactiveX/RxSwiftをクローンする Rx.xcworkspace を開いて、RxSwiftをビルド ビルドスキームを RxSwift-OSX に変更 ビルド (Cmd + B) Observables Observables は時間とともに送信されるイベントの列（ストリーム）。 Marble Diagrams （マーブルダイアグラム）はObservables（データストリーム）を視覚化する図形で、下の図のようなもの。 ---◯

RxSwiftの簡単な機能を使ってみました。 インストール CocoaPodsで下の3つをインストールします。 pod 'RxSwift', '~> 2.0.0-alpha' pod 'RxCocoa', '~> 2.0.0-alpha' pod 'RxBlocking', '~> 2.0.0-alpha' テキストフィールドの入力イベントのサンプル tf1とtf2の合計がtf3に反映されるサンプルを作ってみました。 import RxSwift import RxCocoa let tf1 = UITextField(frame: CGRect(x: 100, y: 100, width: 40, height: 20)) let tf2 = UITextField(frame: CGRect(x: 100, y: 150, width: 40, height: 20)) let tf3