title: Android Retrofit 2 + RxJava: listen to endless stream
body: <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>