Skip to content

Commit f8bb431

Browse files
committed
implement AutoCloseable
1 parent 9ae8c9f commit f8bb431

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

src/AndroidClient/client/src/main/java/net/servicestack/client/sse/ServerEventsClient.java

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@
2626
* Created by mythz on 2/9/2017.
2727
*/
2828

29-
public class ServerEventsClient {
29+
public class ServerEventsClient implements AutoCloseable {
3030
private String baseUri;
3131
private String[] channels;
3232
private String eventStreamPath;
@@ -382,6 +382,11 @@ private void processOnHeartbeatMessage(ServerEventMessage e) {
382382
onHeartbeatReceived(new ServerEventHeartbeat().populate(e, JsonUtils.toJsonObject(e.getJson())));
383383
}
384384

385+
@Override
386+
public void close() throws Exception {
387+
stop();
388+
}
389+
385390
class EventStream implements Runnable {
386391

387392
ServerEventsClient client;

0 commit comments

Comments
 (0)