From 6b0afcbdb32866c482a2e278391e70fc4cca182c Mon Sep 17 00:00:00 2001 From: Dan Brooke Date: Tue, 1 Jun 2021 15:28:05 +0200 Subject: [PATCH] Allow Monix to cancel the request --- .../phantom/monix/execution/MonixPromiseInterface.scala | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/phantom-monix/src/main/scala/com/outworkers/phantom/monix/execution/MonixPromiseInterface.scala b/phantom-monix/src/main/scala/com/outworkers/phantom/monix/execution/MonixPromiseInterface.scala index 6e70fd569..98f01a03d 100644 --- a/phantom-monix/src/main/scala/com/outworkers/phantom/monix/execution/MonixPromiseInterface.scala +++ b/phantom-monix/src/main/scala/com/outworkers/phantom/monix/execution/MonixPromiseInterface.scala @@ -52,7 +52,9 @@ class MonixPromiseInterface extends PromiseInterface[Task, Task]{ } Futures.addCallback(source, callback, executor.asInstanceOf[ExecutionContextExecutor]) - Cancelable.empty + Cancelable { () => + source.cancel(true) + } } }