Commit d87825b1 authored by Adrien Béraud's avatar Adrien Béraud

call service: comment-out connection managment

Change-Id: I9a88c3ce9cb21db51a7d442fe968840e04673605
parent 012f1cb0
......@@ -81,8 +81,8 @@ public class CallService {
private final PublishSubject<SipCall> callSubject = PublishSubject.create();
private final PublishSubject<Conference> conferenceSubject = PublishSubject.create();
private final Set<String> currentConnections = new HashSet<>();
private final BehaviorSubject<Integer> connectionSubject = BehaviorSubject.createDefault(0);
// private final Set<String> currentConnections = new HashSet<>();
// private final BehaviorSubject<Integer> connectionSubject = BehaviorSubject.createDefault(0);
public Observable<Conference> getConfsUpdates() {
return conferenceSubject;
......@@ -109,11 +109,11 @@ public class CallService {
.filter(c -> c.getId().equals(confId));//getConfUpdates(call);*/
}
public Observable<Boolean> getConnectionUpdates() {
/*public Observable<Boolean> getConnectionUpdates() {
return connectionSubject
.map(i -> i > 0)
.distinctUntilChanged();
}
}*/
private void updateConnectionCount() {
//connectionSubject.onNext(currentConnections.size() - 2*currentCalls.size());
......@@ -478,8 +478,8 @@ public class CallService {
public void connectionUpdate(String id, int state) {
Log.d(TAG, "connectionUpdate: " + id + " " + state);
switch(state) {
// Log.d(TAG, "connectionUpdate: " + id + " " + state);
/*switch(state) {
case 0:
currentConnections.add(id);
break;
......@@ -488,7 +488,7 @@ public class CallService {
currentConnections.remove(id);
break;
}
updateConnectionCount();
updateConnectionCount();*/
}
void callStateChanged(String callId, String newState, int detailCode) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment