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) + } } }