Android Retrofit 2 + RxJava: listen to endless stream
<p>Can I use Retrofit + RxJava to listen to an endless stream? For instance the Twitter stream. What I have is this:</p>

<pre><code>public interface MeetupAPI {
    @GET("http://stream.meetup.com/2/rsvps/")
    Observable&lt;RSVP&gt; getRSVPs();
}

MeetupAPI api = new Retrofit.Builder()
            .baseUrl(MeetupAPI.RSVP_API)
            .addCallAdapterFactory(RxJavaCallAdapterFactory.create())
            .addConverterFactory(GsonConverterFactory.create())
            .build()
            .create(MeetupAPI.class);

api.getRSVPs()
        .subscribeOn(Schedulers.newThread())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(rsvp -&gt; Log.d(TAG, "got rsvp"),
                error -&gt; Log.d(TAG, "error: " + error),
                () -&gt; Log.d(TAG, "onComplete"));
</code></pre>

<p>but the "onComplete" is invoked after the first object has been parsed. Is there a way to tell Retrofit to stay open until further notice?</p>