Skip to content

Commit 5c4dc50

Browse files
author
Joe Hansche
committed
Switch subscribe() to use getCurrentSessionTokenAsync()
1 parent 6f95882 commit 5c4dc50

File tree

1 file changed

+8
-3
lines changed

1 file changed

+8
-3
lines changed

ParseLiveQuery/src/main/java/com/parse/ParseLiveQueryClientImpl.java

Lines changed: 8 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -221,9 +221,14 @@ private Subscription<T> subscriptionForRequestId(int requestId) {
221221
return subscriptions.get(requestId);
222222
}
223223

224-
private void sendSubscription(Subscription<T> subscription) {
225-
String sessionToken = ParseUser.getCurrentSessionToken();
226-
sendOperationAsync(new SubscribeClientOperation<>(subscription.getRequestId(), subscription.getQueryState(), sessionToken));
224+
private void sendSubscription(final Subscription<T> subscription) {
225+
ParseUser.getCurrentSessionTokenAsync().onSuccessTask(new Continuation<String, Task<Void>>() {
226+
@Override
227+
public Task<Void> then(Task<String> task) throws Exception {
228+
String sessionToken = task.getResult();
229+
return sendOperationAsync(new SubscribeClientOperation<>(subscription.getRequestId(), subscription.getQueryState(), sessionToken));
230+
}
231+
});
227232
}
228233

229234
private void sendUnsubscription(Subscription subscription) {

0 commit comments

Comments
 (0)