TouchInstinct
/
RoboSwag-components
304
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

static fix

This commit is contained in:
Gavriil Sitnikov 2016-04-14 19:22:47 +03:00
parent a840abe9d6
commit 01a10756b9
1 changed files with 20 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
src/main/java/ru/touchin/roboswag/components/telephony/IsCallingObserver.java
View File

@ -23,10 +23,10 @@ import android.Manifest;
import android.content.Context; import android.content.Context;
import android.support.annotation.NonNull; import android.support.annotation.NonNull;
import android.support.annotation.RequiresPermission; import android.support.annotation.RequiresPermission;
import android.telephony.PhoneStateListener;
import android.telephony.TelephonyManager; import android.telephony.TelephonyManager;
import rx.Observable; import rx.Observable;
import rx.Subscriber;
/** /**
* Created by Gavriil Sitnikov on 02/11/2015. * Created by Gavriil Sitnikov on 02/11/2015.
@ -44,13 +44,7 @@ public final class IsCallingObserver {
isCallingObservable = Observable isCallingObservable = Observable
.<Boolean>create(subscriber -> { .<Boolean>create(subscriber -> {
final TelephonyManager phoneStateManager = (TelephonyManager) context.getSystemService(Context.TELEPHONY_SERVICE); final TelephonyManager phoneStateManager = (TelephonyManager) context.getSystemService(Context.TELEPHONY_SERVICE);
phoneStateManager.listen(new PhoneStateListener() { phoneStateManager.listen(new PhoneStateListener(subscriber), PhoneStateListener.LISTEN_CALL_STATE);
@Override
public void onCallStateChanged(final int state, final String incomingNumber) {
super.onCallStateChanged(state, incomingNumber);
subscriber.onNext(isCallingState(state));
}
}, PhoneStateListener.LISTEN_CALL_STATE);
subscriber.onNext(isCallingState(phoneStateManager.getCallState())); subscriber.onNext(isCallingState(phoneStateManager.getCallState()));
}) })
.distinctUntilChanged() .distinctUntilChanged()
@ -64,4 +58,22 @@ public final class IsCallingObserver {
return isCallingObservable; return isCallingObservable;
} }
private static class PhoneStateListener extends android.telephony.PhoneStateListener {
@NonNull
private final Subscriber<? super Boolean> subscriber;
public PhoneStateListener(@NonNull final Subscriber<? super Boolean> subscriber) {
super();
this.subscriber = subscriber;
}
@Override
public void onCallStateChanged(final int state, final String incomingNumber) {
super.onCallStateChanged(state, incomingNumber);
subscriber.onNext(isCallingState(state));
}
}
} }