Drop custom backpressure support in favor of RxJava 1.1's built-in buffer latest.

Author: JakeWharton

CHANGELOG.md

@@ -1,6 +1,12 @@
 Change Log
 =========
 
+Version 0.5.0 *(In Development)*
+--------------------------------
+
+ * Requires RxJava 1.1.0 or newer.
+
+
 Version 0.4.1 *(2015-10-19)*
 ----------------------------
 

build.gradle

@@ -29,7 +29,7 @@ ext {
   timber = 'com.jakewharton.timber:timber:2.7.1'
   autoParcel = 'com.github.frankiesardo:auto-parcel:0.3'
   autoParcelProcessor = 'com.github.frankiesardo:auto-parcel-processor:0.3'
-  rxJava = 'io.reactivex:rxjava:1.0.14'
+  rxJava = 'io.reactivex:rxjava:1.1.0'
   rxAndroid = 'io.reactivex:rxandroid:1.0.1'
   rxBinding = 'com.jakewharton.rxbinding:rxbinding:0.2.0'
   truth = 'com.google.truth:truth:0.27'

sqlbrite/src/main/java/com/squareup/sqlbrite/BackpressureBufferLastOperator.java

@@ -106,7 +106,7 @@ public QueryObservable createQuery(@NonNull final Uri uri, @Nullable final Strin
     };
     Observable<Query> queryObservable = Observable.create(subscribe) //
         .startWith(query) //
-        .lift(BackpressureBufferLastOperator.<Query>instance());
+        .onBackpressureLatest();
     return new QueryObservable(queryObservable);
   }
 

sqlbrite/src/main/java/com/squareup/sqlbrite/BriteContentResolver.java

@@ -309,7 +309,7 @@ private QueryObservable createQuery(final Func1<Set<String>, Boolean> tableFilte
             return query;
           }
         }) //
-        .lift(BackpressureBufferLastOperator.<Query>instance());
+        .onBackpressureLatest();
     return new QueryObservable(queryObservable);
   }