feat: update cancel stream tiout method

eisbilir · eisbilir · commit e497ee8d2e8d · 2023-09-29T13:13:08.000+03:00
diff --git a/src/main/java/com/topcoder/dal/DBAccessor.java b/src/main/java/com/topcoder/dal/DBAccessor.java
@@ -379,7 +379,7 @@ private boolean debounce() {
 
             private boolean cancelStreamTimeout() {
                 ScheduledFuture<?> currentFuture = streamTimeoutFuture.get();
-                return currentFuture == null || currentFuture.cancel(false);
+                return currentFuture == null || currentFuture.isCancelled() || currentFuture.cancel(false);
             }
 
             private ScheduledFuture<?> scheduleStreamTimeout() {

Original file line number	Diff line number	Diff line change
`@@ -379,7 +379,7 @@ private boolean debounce() {`
`379`	`379`
`380`	`380`	`private boolean cancelStreamTimeout() {`
`381`	`381`	`ScheduledFuture<?> currentFuture = streamTimeoutFuture.get();`
`382`		`- return currentFuture == null \|\| currentFuture.cancel(false);`
	`382`	`+ return currentFuture == null \|\| currentFuture.isCancelled() \|\| currentFuture.cancel(false);`
`383`	`383`	`}`
`384`	`384`
`385`	`385`	`private ScheduledFuture<?> scheduleStreamTimeout() {`