Skip to content

Commit 0969a14

Browse files
committed
Some stop logic
1 parent b82c91a commit 0969a14

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

src/SignalR/clients/java/signalr/src/main/java/com/microsoft/signalr/LongPollingTransport.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -59,6 +59,7 @@ private Completable poll(String url){
5959
this.active = false;
6060
} else if (response.getStatusCode() != 200) {
6161
logger.error("Unexpected response code {}", response.getStatusCode());
62+
this.active = false;
6263
} else {
6364
logger.info("Message received");
6465
this.onReceive(response.getContent());
@@ -91,6 +92,10 @@ public void setOnClose(TransportOnClosedCallback onCloseCallback) {
9192

9293
@Override
9394
public Completable stop() {
95+
logger.info("LongPolling transport stopped.");
96+
this.active = false;
97+
this.client.delete(this.url);
98+
this.onClose.invoke(null);
9499
return Completable.complete();
95100
}
96101
}

0 commit comments

Comments
 (0)