|
@@ -1480,7 +1480,7 @@ public class CallActivity extends CallBaseActivity {
|
|
.observeOn(AndroidSchedulers.mainThread())
|
|
.observeOn(AndroidSchedulers.mainThread())
|
|
.repeatWhen(observable -> observable)
|
|
.repeatWhen(observable -> observable)
|
|
.takeWhile(observable -> isConnectionEstablished())
|
|
.takeWhile(observable -> isConnectionEstablished())
|
|
- .retry(3, observable -> isConnectionEstablished())
|
|
|
|
|
|
+ .retry(observable -> isConnectionEstablished())
|
|
.subscribe(new Observer<SignalingOverall>() {
|
|
.subscribe(new Observer<SignalingOverall>() {
|
|
@Override
|
|
@Override
|
|
public void onSubscribe(@io.reactivex.annotations.NonNull Disposable d) {
|
|
public void onSubscribe(@io.reactivex.annotations.NonNull Disposable d) {
|