Android Retrofit 2 + RxJava: Listen To Endless Stream
Answer : Here my solution: You can use the @Streaming annotation: public interface ITwitterAPI { @GET("/2/rsvps") @Streaming Observable<ResponseBody> twitterStream(); } ITwitterAPI api = new Retrofit.Builder() .baseUrl("http://stream.meetup.com") .addCallAdapterFactory(RxJavaCallAdapterFactory.create()) .build().create(ITwitterAPI.class); With @Streaming we can get raw input From ResponseBody . Here my function to wrap body divided by lines with events: public static Observable<String> events(BufferedSource source) { return Observable.create(new Observable.OnSubscribe<String>() { @Override public void call(Subscriber<? super String> subscriber) { try { while (!source.exhausted()) { subscriber.onNext(source.readUtf8Line()); } subscriber.onCompleted(); } catch (IOException e)...