RxJavaã®ã‚¨ãƒ©ãƒ¼ãƒãƒ³ãƒ‰ãƒªãƒ³ã‚° - QiitaRxJavaã§ã¯éžåŒæœŸå‡¦ç†ãªã©ã§éžå¸¸ã«ä¾¿åˆ©ãªãƒ©ã‚¤ãƒ–ラリã§ã™ãŒã€ãã®ã‚¨ãƒ©ãƒ¼ãƒãƒ³ãƒ‰ãƒªãƒ³ã‚°ã‚‚ã¨ã¦ã‚‚スマートã«è¡Œã†ã“ã¨ãŒã§ãã¾ã™ã€‚ã“ã“ã§ã¯RxJavaã®ã‚¨ãƒ©ãƒ¼ãƒãƒ³ãƒ‰ãƒªãƒ³ã‚°ã®è©³ç´°ã«ã¤ã„ã¦èª¬æ˜Žã—ãŸã„ã¨æ€ã„ã¾ã™ã€‚ subscribeã§ã®ã‚¨ãƒ©ãƒ¼å‡¦ç† 通常ã¯subscribe()ã§ã‚¨ãƒ©ãƒ¼ã‚’å—ã‘å–ã£ã¦ãƒãƒ³ãƒ‰ãƒªãƒ³ã‚°ã™ã‚‹ã“ã¨ã¨ãªã‚‹ã¨æ€ã„ã¾ã™ã€‚ Observable .create(new Observable.OnSubscribe<String>() { @Override public void call(Subscriber<? super String> subscriber) { log("subscribe"); subscriber.onNext("emit 1"); subscriber.onNext("emit 2"); subscriber.onError(new Throwable());
{{#tags}}- {{label}}
{{/tags}}