Managing State with RxJava by Jake Wharton
Please subscribe to our YouTube channel @ https://bit.ly/devoxx-youtube Like us on Facebook @ https://www.facebook.com/devoxxcom Follow us on Twitter @ https://twitter.com/devoxx RxJava's use in building Android apps has grown rapidly! Combining and composing synchronous and asynchronous sources of data has become easy. That burden that remains is where to put the overall state of the applicati
å„言語ã«åºƒã¾ã£ãŸRx（Reactive Extensionsã€ReactiveX）ã®ç¾çŠ¶ãƒ»ã“ã‚Œã‹ã‚‰ - Build Insider
ã§ã¯ãªãœãƒãƒƒãƒˆãƒ•ãƒªãƒƒã‚¯ã‚¹ãŒãƒžã‚¤ã‚¯ãƒã‚½ãƒ•ãƒˆç™ºç¥¥ã®ãƒ†ã‚¯ãƒŽãƒã‚¸ã‚’利用ã™ã‚‹ã‚ˆã†ã«ãªã£ãŸã®ã ã‚ã†ã‹ã€‚実ã¯ã€RxJavaã®åˆæœŸã®é–‹ç™ºè€…ã§ã‚ã‚‹Jafar Husainæ°ã¯ã€ã‚‚ã¨ã‚‚ã¨ãƒžã‚¤ã‚¯ãƒã‚½ãƒ•ãƒˆã«å‹¤ã‚ã¦ã„ã¦ã€ä¸–ç•Œã§æœ€åˆã«Reactive Extensionsを紹介ã—ãŸäººç‰©ã§ã‚‚ã‚ã‚‹ã®ã 。ãã®å¾Œã«ãƒãƒƒãƒˆãƒ•ãƒªãƒƒã‚¯ã‚¹ã«è»¢è·ã—ã€RxJavaã®èª•ç”Ÿã«æ·±ãé–¢ã‚ã‚‹ã“ã¨ã«ãªã‚‹ã€‚ 一方ã§ã‚ªãƒªã‚¸ãƒŠãƒ«ã®Rx.NETã®ä½œè€…ã§ã‚ã‚‹Erik Meijeræ°ã‚‚ã¾ãŸã€ãƒžã‚¤ã‚¯ãƒã‚½ãƒ•ãƒˆã‚’辞ã‚ãŸå¾Œã«ã€Hackã‚„Dartãªã©ã®æ–°èˆˆè¨€èªžã®æ”¯æ´ã«é–¢ã‚ã‚‹ä»–ã€Principles of Reactive Programmingã¨ã„ã£ãŸå¦ç¿’コースをScalaã®ä½œè€…ã§ã‚ã‚‹Martin Oderskyæ°ã‚‰ã¨é–‹è¬›ã™ã‚‹ãªã©ã€è¨€èªžã®æž を超ãˆã¦æ´»èºã—ã¦ã„る。 Rxã¨ãƒžã‚¤ã‚¯ãƒã‚½ãƒ•ãƒˆã®ã‚ªãƒ¼ãƒ—ンソース 昨今ã®ãƒžã‚¤ã‚¯ãƒã‚½ãƒ•ãƒˆã®ã‚ªãƒ¼ãƒ—ンソースã¸ã®å‚¾å€’ã‚’ç–‘ã†ã‚‚ã®ã¯ã‚‚ã¯ã‚„ã„ãªã„ã
RxJava's repeatWhen and retryWhen, explained
repeatWhen and retryWhen are fairly baffling at first glance. For starters, they are serious contenders for "most confusing marble diagrams": They're useful operators: they allow you to conditionally resubscribe to Observables that have terminated. I recently studied how they worked and I want to try to explain them (since it took me a while to grasp). Repeat vs. Retry First of all, what is the di
Loading data from multiple sources with RxJava
Suppose I have some Data that I query from the network. I could simply hit the network each time I need the data, but caching the data on disk and in memory would be much more efficient. More specifically, I want a setup that: Occasionally performs queries from the network for fresh data. Retrieves data as quickly as possible otherwise (by caching network results). I'd like to present an implement
RxPropertyã§RxJavaã¨Android Data Bindingを連æºã™ã‚‹ - Qiita
ã¿ã˜ã‹ãã¾ã¨ã‚ RxJavaã¨Android Data Bindingを連æºã—ã¦MVVMã™ã‚‹ãƒ©ã‚¤ãƒ–ラリを作りã¾ã—ãŸâ†’RxProperty Android （2017/02/09 v3.0.0ãƒãƒ¼ã‚¸ãƒ§ãƒ³ã‚¢ãƒƒãƒ—ã«ä¼´ã„編集） ã¯ã˜ã‚ã« Android標準ã®éžåŒæœŸå‡¦ç†ã®é¢å€’ã•ã‹ã‚‰ã€Android開発ã«RxJavaã‚’å°Žå…¥ã™ã‚‹æ–¹ãŒå¢—ãˆã¦ã„ã¾ã™ã€‚ 実際ã«RxJavaを使用ã—ã¦ã¿ã‚‹ã¨ã€éžåŒæœŸå‡¦ç†ã®ã¿ãªã‚‰ãšã‚¤ãƒ™ãƒ³ãƒˆã‚„å„層ã®I/Fãªã©ã€ã‚ã‚Šã¨ã‚らゆるもã®ã‚’ストリームã¨ã—ã¦è¡¨ç¾ã—ãŸããªã‚‹ã¨æ€ã„ã¾ã™ã€‚ ãã®çµæžœã€ã‚¹ãƒˆãƒªãƒ¼ãƒ 末尾ã®subscribeã¯ã»ã¨ã‚“ã©ãŒViewæ“作ã¨ãªã‚Šã€ã‚¨ãƒŸãƒƒãƒˆã•ã‚ŒãŸå€¤ã‚’セットã™ã‚‹ã ã‘ã®ã‚ˆã†ãªå˜ç´”ãªå‡¦ç†ã‚’ç¹°ã‚Šè¿”ã™ã“ã¨ã«ãªã‚Šã¾ã™ã€‚ 当然「io.reactivex.Observableã«æµã‚Œã¦ããŸå€¤ãŒãã®ã¾ã¾Viewã«åæ˜ ã•ã‚Œãªã„ã‹ãªã€ã¨ã®ç™ºæƒ³ãŒç”Ÿã˜ã¾ã™ãŒã€Android Data Bindi
Interactive LINQPad: ãŠæ‰‹è»½ãƒãƒãƒãƒ Rx
LINQPad 㯠.NET コードã®ãŠæ‰‹è»½ãªå®Ÿè¡Œç’°å¢ƒã€ãã—ã¦è‰¯è³ªãªãƒ‡ãƒ¼ã‚¿ ビジュアライザã¨ã—ã¦å…¨ã¦ã® .NET ユーザã®å¿…æºãƒ„ールã¨ã„ã£ã¦ã‚‚éŽè¨€ã§ã¯ãªã„ã¨ã„ãˆã‚‹ã®ã§ã¯ãªã„ã§ã—ょã†ã‹ã€‚入力補完ãªã©ã®ä¸€éƒ¨ã®ä¾¿åˆ©ãªæ©Ÿèƒ½ã¯æœ‰æ–™ã§ã¯ã‚ã‚Šã¾ã™ãŒã€å®Ÿéš›ã®ã¨ã“ã‚ã€è³¼å…¥ã™ã‚‹ä¾¡å€¤ã¯å分ã«ã‚ã‚‹ã¨æ€ã„ã¾ã™ã€‚ ãã‚Œã¯ã•ã¦ãŠãã€LINQPad ã¯ã©ã‚“ãªã‚ªãƒ–ジェクトも .Dump() ã™ã‚Œã°è¦‹ã‚„ã™ã表示ã—ã¦ãれるã¨ã„ã†ã®ãŒæœ€é«˜ã«é…力的ã§ã™ã€‚ã“ã‚Œã ã‘ã§ã‚‚ LINQPad ã¯å分ã«ä¾¿åˆ©ã§ä½¿ã†ä¾¡å€¤ãŒã‚ã‚Šã¾ã™ã€‚ã§ã™ãŒã€LINQPad ã®ä¾¿åˆ©ã•ã¯ãã‚Œã«ç•™ã¾ã‚‹ã‚‚ã®ã§ã¯ã‚ã‚Šã¾ã›ã‚“。 …ã¨ã„ã†ã“ã¨ç‰ã€…を以å‰æ›¸ã„ãŸã‚Šã‚‚ã—ã¾ã—ãŸãŒã€æ–‡ç« ã°ã‹ã‚Šã®è¨˜äº‹ã§ã—ã¦é¢ç™½ã¿ã«ã‚‚å°‘ã—æ¬ ã‘ã¦ã„ã¾ã—ãŸã€‚å…ˆã®è¨˜äº‹ã¯å‰²ã¨ç·è«–çš„ãªå†…容ã ã£ãŸã®ã§ã€è¶£å‘を変ãˆã¦ã€é¢ç™½ã膨らã¾ã›ãã†ãª LINQPad ã®ä¾¿åˆ©ãªä½¿ã„æ–¹ã«ã¤ã„ã¦ã€æŠ˜ã«ãµã‚Œã¦æ›¸ã„ã¦ã„ã“ã†ã¨æ€ã„ã¾ã™ã€‚ ã•ã¦ã€
Unit Testing RxJava Observables
At ribot, we started using RxJava a few months ago and now it’s become a core element in the architecture of the Android apps we create. There are many benefits that come with it, but the learning curve is steep and quite often we still find ourselves trying to get our heads around those “beautiful†diagrams that explain how operators work. The first step to rx-ify our architecture was to change t
RxJavaå¦ç¿’ã®ãƒ˜ã‚™ã‚¹ãƒˆãƒ•ã‚šãƒ©ã‚¯ãƒ†ã‚£ã‚¹ã£ã»ã‚šã„ã‚‚ã®
Incident Response Practices: Waroom's Features and Future Challenges
Don't break the chain: use RxJava's compose() operator
One nice aspect of RxJava is that you can see how data is transformed through a series of operators: Observable.from(someSource) .map(data -> manipulate(data)) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(data -> doSomething(data)); What if you have a set of operators that you want to reuse for multiple streams? For example, I frequently use subscribeOn() and
Native Vs. Hybrid App Development: 5 Reasons To Go Native - stable|kernel
About UsWe are a software company on a mission to provide the most innovative companies with the most innovative solutions. Our story.Stable Kernel is a digital transformation company based in Atlanta, GA. We have a track record of helping our partners solve their biggest challenges on their digital journey, whether they need insights or implementation. Every day, millions of people rely on softwa
ã€ç¿»è¨³ã€‘ã‚ãªãŸãŒæ±‚ã‚ã¦ã„ãŸãƒªã‚¢ã‚¯ãƒ†ã‚£ãƒ–プãƒã‚°ãƒ©ãƒŸãƒ³ã‚°å…¥é–€ - ninjinkun's diary
original: The introduction to Reactive Programming you've been missing (by @andrestaltz) (translated by @ninjinkun, reviewed by @ma0e) ã‚ãªãŸã¯ãƒªã‚¢ã‚¯ãƒ†ã‚£ãƒ–プãƒã‚°ãƒ©ãƒŸãƒ³ã‚°ã¨å‘¼ã°ã‚Œã‚‹æ–°ã—ã„方法ãŒæ°—ã«ãªã£ã¦ã„る。 勉強ã™ã‚‹ã®ã¯å¤§å¤‰ã§ã€è‰¯ã„æ•™æãŒãªã„ã®ã§ã•ã‚‰ã«é›£ã—ã„。ç§ãŒå‹‰å¼·ã‚’始ã‚ãŸã¨ãã¯ã€ã¾ãšãƒãƒ¥ãƒ¼ãƒˆãƒªã‚¢ãƒ«ã‚’探ã—ãŸã€‚見ã¤ã‘ãŸã®ã¯ä¸€æ¡ã‚Šã®å®Ÿè·µçš„ãªã‚¬ã‚¤ãƒ‰ã ã‘ã€ã—ã‹ã‚‚ãれらã¯è¡¨é¢ã‚’ãªãžã£ã¦ã„ã‚‹ã ã‘ã§ã€ãƒªã‚¢ã‚¯ãƒ†ã‚£ãƒ–プãƒã‚°ãƒ©ãƒŸãƒ³ã‚°ã®ã‚¢ãƒ¼ã‚テクãƒãƒ£å…¨ä½“åƒã‚’構築ã—よã†ã¨ã—ã¦ã¯ã„ãªã‹ã£ãŸã€‚ã‚る関数をç†è§£ã™ã‚‹ã®ã«ã€ãƒ©ã‚¤ãƒ–ラリã®ãƒ‰ã‚ュメントã¯å½¹ã«ç«‹ãŸãªã„ã“ã¨ãŒã‚る。 ã“れを見ã¦æ¬²ã—ã„。 Rx.Observable.prototype.flatMapLatest(selector,
RxJava, Tips and Tricks
public interface Observer <T> { void onCompleted(); void onError(java.lang.Throwable throwable); void onNext(T t); } public class Observable <T> { public final static <T> Observable<T> create(OnSubscribe<T> f) public rx.Subscription subscribe(rx.Observer<? super T> observer) // ... } public static interface OnSubscribe<T> extends Action1<Subscriber<? super T>> {} public interface Subscription { pu
Google グループ
Google グループã§ã¯ã€ã‚ªãƒ³ãƒ©ã‚¤ãƒ³ フォーラムやメール ベースã®ã‚°ãƒ«ãƒ¼ãƒ—を作æˆã—ãŸã‚Šã€ã“ã†ã—ãŸãƒ•ã‚©ãƒ¼ãƒ©ãƒ やグループã«å‚åŠ ã—ãŸã‚Šã™ã‚‹ã“ã¨ã§ã€å¤§å‹¢ã®ãƒ¦ãƒ¼ã‚¶ãƒ¼ã¨æƒ…å ±ã®å…±æœ‰ã‚„ディスカッションを行ã†ã“ã¨ãŒã§ãã¾ã™ã€‚
Release 1.0.0 · ReactiveX/RxJava
After 2+ years of internal and open source development, 3600+ commits, 100+ releases, and with the help of 97 contributors RxJava has hit version 1.0.0. Thank you @headinthebox @zsxwing @samuelgruetter @akarnokd @quidryan @DavidMGross @abersnaze @jmhofer @mairbek @mttkay @daveray @mattrjacobs @michaeldejong @MarioAriasC @johngmyers @pron @jbripley @davidmoten @gliptak @johnhmarks @jloisel @billyy
The History of Reactive Extensions
1. The History of Reactive ExtensionsHow extended Rx across languages 2014/10/28 RxJava Night #rxjnight Yoshifumi Kawai -@neuecc 2. SelfIntroduction @仕事 æ ªå¼ä¼šç¤¾ã‚°ãƒ©ãƒ‹å–ç· å½¹CTO 神ç„ã®ãƒ´ã‚¡ãƒ«ãƒãƒ©ã‚²ãƒ¼ãƒˆ, モンスターãƒãƒ³ã‚¿ãƒ¼ãƒã‚¢ã‚ªãƒ–カード 最先端C#ã«ã‚ˆã‚‹ãƒã‚¤ãƒ‘フォーマンスWebアプリケーション @個人活動 Microsoft MVP for Visual C# / 野良C#エヴァンジェリスト Web http://neue.cc/ Twitter @neuecc
Shows - Event & Video Content
Ready to supercharge your Azure game right within GitHub Copilot? Dive into our latest set of videos where we break down six must-try features of GitHub Copilot for Azure. From deploying containers and managing AI models to exploring resources and planning migrations, we've got you covered. Check out the videos to see great examples of how GitHub Copilot for Azure can make your cloud projects smoo
リリースã€éšœå®³æƒ…å ±ãªã©ã®ã‚µãƒ¼ãƒ“スã®ãŠçŸ¥ã‚‰ã›
最新ã®äººæ°—エントリーã®é…ä¿¡
j次ã®ãƒ–ックマーク
kå‰ã®ãƒ–ックマーク
lã‚ã¨ã§èªã‚€
eコメント一覧を開ã
oページを開ã
onError throws Exception after Flowable has been unsubscribed · Issue #4894 · ReactiveX/RxJava
Reactive Streams 入門 #jjug
Recursive Observables with RxJava
分ã‹ã£ãŸæ°—ã«ãªã‚‹ã¯ã˜ã‚ã¦ã®RxJava
{{#tags}}- {{label}}
{{/tags}}