mirror
/
Signal-Android
kopia lustrzana https://github.com/ryukoposting/Signal-Android
1
0
Forkuj 0
Kod Zgłoszenia Packages Projekty Wydania Wiki Aktywność

Use tryOnError in CdsiSocket.

fork-5.53.8
Greyson Parrelli 2022-10-03 10:50:12 -04:00
rodzic 3b1ecc7015
commit 04822bacdc
1 zmienionych plików z 3 dodań i 3 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

6
libsignal/service/src/main/java/org/whispersystems/signalservice/api/services/CdsiSocket.java
Wyświetl plik

@ -157,7 +157,7 @@ final class CdsiSocket {
} catch (IOException | AttestationDataException | Cds2CommunicationFailureException e) { } catch (IOException | AttestationDataException | Cds2CommunicationFailureException e) {
Log.w(TAG, e); Log.w(TAG, e);
webSocket.close(1000, "OK"); webSocket.close(1000, "OK");
emitter.onError(e); emitter.tryOnError(e);
} }
} }
@ -170,13 +170,13 @@ final class CdsiSocket {
Log.w(TAG, "Remote side is closing with non-normal code " + code); Log.w(TAG, "Remote side is closing with non-normal code " + code);
webSocket.close(1000, "Remote closed with code " + code); webSocket.close(1000, "Remote closed with code " + code);
stage.set(Stage.FAILED); stage.set(Stage.FAILED);
emitter.onError(new NonSuccessfulResponseCodeException(code)); emitter.tryOnError(new NonSuccessfulResponseCodeException(code));
} }
} }
@Override @Override
public void onFailure(WebSocket webSocket, Throwable t, Response response) { public void onFailure(WebSocket webSocket, Throwable t, Response response) {
emitter.onError(t); emitter.tryOnError(t);
stage.set(Stage.FAILED); stage.set(Stage.FAILED);
webSocket.close(1000, "OK"); webSocket.close(1000, "OK");
} }