はてなブックマーク

// サンプル1 Observable .just(1, 2, 3, 4, 5) .flatMap(it -> Observable .just(it) .delay(5 - it, TimeUnit.SECONDS, Schedulers.io()) ) .subscribe( it -> Log.d(TAG, "num:" + it) ); 11-21 21:28:02.470 3161-3186/com.kazy.rxjavaplayground D/MainActivity: num:5 11-21 21:28:03.470 3161-3185/com.kazy.rxjavaplayground D/MainActivity: num:4 11-21 21:28:04.471 3161-3184/com.kazy.rxjavaplayground D/MainActivity: n

昨年RxJava Adavent Calendarというものをやっていて、その中でRxJava 2.x系の開発についてすこし紹介しました。 昨年末では、まだまだ実用段階という雰囲気ではなかった2.xブランチですが、先程レポジトリ覗いたらかなり状況が変わっていたので少しだけまとめました。 2.xの特徴 continued support for Java 6+ & Android 2.3+ Reactive Streams compatibility performance gains through design changes learned through the 1.x cycle Reactive Streamsの仕様に準拠したというのが一番大きいですね。Reactive Streamsについては、冒頭でリンクしたエントリをご参照下さい。 リリーススケジュール 2016/08/26

若干の釣り気味ですが、RxJavaを利用されている方には結構重要そうだよな−と思う話題だったのでQiitaにまとめました。 ことのはじまり Check out the new fromAsync() operator for adapting callback-based sources into Observables. Stop using create()! https://t.co/3SvYMmgeWx — Jake Wharton (@JakeWharton) 2016年7月10日 なんだかJakeが過激なこと言ってる気配があったので、背景を調べるために少しissueを漁り始めました。 きっかけのissue https://github.com/ReactiveX/RxJava/issues/4177 すごく雑に3行でまとめると、 非Rxの世界の非同期処理をラップするのにObse

TLDR composeはメソッドチェーンの中でObseravbleにアクセスできる最高のオペレーター liftとの違いはObseravbleの中の値にアクセスできるかどうか flatmapとの違いはObseravbleの中の値にアクセスできるかどうか + 実行されるタイミング RxLifecycleはtakeUntilでライフサイクルイベントをbindしてる。 RxJava Advent Calendar 5日目の今日は、composeオペレーターについて紹介します。 composeといえば、最近ではtrello/RxLifecycleでも使われているので、馴染みのある方も多いかもしれませんね。 composeは初日のエントリで紹介したliftと同じくRxJavaのメソッドチェーンを実現している要素の一つです。ではこの二つのオペレータにはどのような違いがあるのでしょうか? liftとco

たまたまChangeLogを読んだので、気になったポイントを紹介します。 Package名を変更した 3系になってcom.squareup.okhttpからokhttp3に変更されています。理由はJakeのブログに詳しく書かれていますが、要約すると、2系のコードと共存出来るようにすることで、部分的/段階的に3系のコードを取り入れることを可能にして、バージョンアップの負担を減らすことが目的のようです。 グローバルなconnection poolの仕組みがなくなった 2系は全てのOkHttpClientのインスタンスがグローバルなコネクションプールを共有していたらしいのですが(知らなかった... )、それがなくなりました。 そのため、3系では一つのOkHttpClientインスタンスをアプリケーション全体で使いまわすことが薦められています。 OkHttpClientが不変になった 2系のOkH

本稿ではRxJavaの2.x系について紹介します。間違っている箇所があればご指摘下さい。 TL;DR 2.x系はReactive Streams準拠に作りなおした実装 (Reactive StreamsとReactive Manifestoは別物) ついでに1.x系よりもハイパフォーマンスな設計を目指している Java 1.8以上を対象としていて、将来的には1.9(JDK9)のFlow APIにも対応する予定がある 当分は1.x系と平行して開発していくので、2.x系に急いで乗り換える必要はない(まだ実用段階ではなさそう) 2.x系の開発の動機 Javaの非同期ストリーム処理の実装は、RxJava, Akka Streams and Reactorなどなど複数あります。少し前に、これら非同期ストリーム処理の基盤部分の標準化をしようという動きがあって、Reactive Streamsというプロ

新しく追加される予定のrx.Completableの紹介記事です。 TL;DR 1.1.1で入る予定。(最新は1.1.0) @Experimentalな機能なので、method名や仕様が変わる可能性がある。 Coldなやつで、Single<Void>に近いがonNextはない。 POST処理とかの際にObservable/Singleの代わりに使うと便利かも。 PullRequest Completable class for valueless event composition(#3439) 1.x向けのバックポート(#3444) (2.xの方は実装に難有りでまだmergeされてないです。) 詳細はPRを見て下さい。 議論の内容をざっくりまとめると、 "なにかの処理"の成功/失敗だけを伝えたい時はあるじゃん。(別に値を渡したくはない) Single<Void>だとonNext(null

はじめに 入門向けにとにかく短くまとめました 言わずと知れたPermissionsDispatcherの紹介記事です ざっくり理解できたらより詳しい記事やドキュメントを読みましょう Mパーミッションに対応するサンプルコード このコードは、android.permission.CALL_PHONEの権限が取得できていない場合に、ボタンをクリックすると落ちます。(手元で試して見る場合は、適当なレイアウトXMLを用意して下さい) public class MainActivity extends AppCompatActivity { @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_

RxJava AdventCalendarの初日は、liftについて、紹介します。 初学者なので間違った理解があるかもしれませんが、その際はコメントなどでご指摘頂けると幸いです。 また、一部説明の端折る部分があると思いますが、簡略化のためなのでご了承下さい liftとはなにか Rxjavaはメソッドチェーンで処理を繋げて書くのが一般的ですが、このメソッドチェーンを実現しているのがliftです。 普段の開発でliftを見かけることは少ないと思いますが、mapやfilterなど殆どのオペレーターの中身はliftとOperator<R, T> の組み合わせで作られています。liftを理解すると、自分でカスタムオペレーターも作ることも出来ます。 [Implementing Your Own Operators](https://github.com/ ReactiveX/RxJava/wiki/I

<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android" xmlns:tools="http://schemas.android.com/tools" android:id="@+id/container" android:layout_width="match_parent" android:layout_height="match_parent" android:orientation="vertical" android:layout_marginTop="100dp" > <!-- このTextViewをピヨっとさせたい --> <TextView android:id="@+id/childview" android:layout_width="match_parent" android:la

Deleted articles cannot be recovered. Draft of this article would be also deleted. Are you sure you want to delete this article?