Fix sample: RSSI

dariuszseweryn · web-flow · commit 4bbd856d1e05 · 2018-07-04T10:21:42.000+02:00
Closes dariuszseweryn#454
diff --git a/sample/src/main/java/com/polidea/rxandroidble2/sample/example5_rssi_periodic/RssiPeriodicExampleActivity.java b/sample/src/main/java/com/polidea/rxandroidble2/sample/example5_rssi_periodic/RssiPeriodicExampleActivity.java
@@ -42,10 +42,10 @@ public void onConnectToggleClick() {
         } else {
             connectionDisposable = bleDevice.establishConnection(false)
                     .compose(bindUntilEvent(PAUSE))
-                    .observeOn(AndroidSchedulers.mainThread())
                     .doFinally(this::clearSubscription)
                     .flatMap(rxBleConnection -> // Set desired interval.
                             Observable.interval(2, SECONDS).flatMapSingle(sequence -> rxBleConnection.readRssi()))
+                    .observeOn(AndroidSchedulers.mainThread())
                     .subscribe(this::updateRssi, this::onConnectionFailure);
         }
     }

Original file line number	Diff line number	Diff line change
`@@ -42,10 +42,10 @@ public void onConnectToggleClick() {`
`42`	`42`	`} else {`
`43`	`43`	`connectionDisposable = bleDevice.establishConnection(false)`
`44`	`44`	`.compose(bindUntilEvent(PAUSE))`
`45`		`- .observeOn(AndroidSchedulers.mainThread())`
`46`	`45`	`.doFinally(this::clearSubscription)`
`47`	`46`	`.flatMap(rxBleConnection -> // Set desired interval.`
`48`	`47`	`Observable.interval(2, SECONDS).flatMapSingle(sequence -> rxBleConnection.readRssi()))`
	`48`	`+ .observeOn(AndroidSchedulers.mainThread())`
`49`	`49`	`.subscribe(this::updateRssi, this::onConnectionFailure);`
`50`	`50`	`}`
`51`	`51`	`}`