diff --git a/runtime/engine/src/test/java/io/aklivity/zilla/runtime/engine/test/internal/k3po/ext/behavior/ZillaChildChannelSink.java b/runtime/engine/src/test/java/io/aklivity/zilla/runtime/engine/test/internal/k3po/ext/behavior/ZillaChildChannelSink.java
index c195cc08cb..1529921c0d 100644
--- a/runtime/engine/src/test/java/io/aklivity/zilla/runtime/engine/test/internal/k3po/ext/behavior/ZillaChildChannelSink.java
+++ b/runtime/engine/src/test/java/io/aklivity/zilla/runtime/engine/test/internal/k3po/ext/behavior/ZillaChildChannelSink.java
@@ -72,6 +72,10 @@ protected void abortOutputRequested(
         {
             channel.engine.abortOutput(channel, abortFuture);
         }
+        else
+        {
+            abortFuture.setSuccess();
+        }
     }
 
     @Override
@@ -86,6 +90,10 @@ protected void abortInputRequested(
         {
             channel.engine.abortInput(channel, abortFuture);
         }
+        else
+        {
+            abortFuture.setSuccess();
+        }
     }
 
     @Override
diff --git a/runtime/engine/src/test/java/io/aklivity/zilla/runtime/engine/test/internal/k3po/ext/behavior/ZillaClientChannelSink.java b/runtime/engine/src/test/java/io/aklivity/zilla/runtime/engine/test/internal/k3po/ext/behavior/ZillaClientChannelSink.java
index 60062e2f62..359ef8caa8 100644
--- a/runtime/engine/src/test/java/io/aklivity/zilla/runtime/engine/test/internal/k3po/ext/behavior/ZillaClientChannelSink.java
+++ b/runtime/engine/src/test/java/io/aklivity/zilla/runtime/engine/test/internal/k3po/ext/behavior/ZillaClientChannelSink.java
@@ -79,7 +79,11 @@ protected void abortOutputRequested(
         ZillaChannel channel = (ZillaChannel) evt.getChannel();
         ChannelFuture abortFuture = evt.getFuture();
 
-        if (!channel.isWriteClosed())
+        if (channel.isWriteAborted())
+        {
+            abortFuture.setSuccess();
+        }
+        else if (!channel.isWriteClosed())
         {
             channel.engine.abortOutput(channel, abortFuture);
         }
@@ -93,7 +97,11 @@ protected void abortInputRequested(
         ZillaChannel channel = (ZillaChannel) evt.getChannel();
         ChannelFuture abortFuture = evt.getFuture();
 
-        if (!channel.isReadClosed())
+        if (channel.isReadAborted())
+        {
+            abortFuture.setSuccess();
+        }
+        else if (!channel.isReadClosed())
         {
             channel.engine.abortInput(channel, abortFuture);
         }
diff --git a/runtime/engine/src/test/java/io/aklivity/zilla/runtime/engine/test/internal/k3po/ext/behavior/ZillaEngine.java b/runtime/engine/src/test/java/io/aklivity/zilla/runtime/engine/test/internal/k3po/ext/behavior/ZillaEngine.java
index 8cf1269b45..dece8a6a00 100644
--- a/runtime/engine/src/test/java/io/aklivity/zilla/runtime/engine/test/internal/k3po/ext/behavior/ZillaEngine.java
+++ b/runtime/engine/src/test/java/io/aklivity/zilla/runtime/engine/test/internal/k3po/ext/behavior/ZillaEngine.java
@@ -617,7 +617,11 @@ public void run()
         {
             try
             {
-                if (!channel.isWriteClosed())
+                if (channel.isWriteAborted())
+                {
+                    handlerFuture.setSuccess();
+                }
+                else if (!channel.isWriteClosed())
                 {
                     ZillaEngine engine = channel.engine;
                     int scopeIndex = channel.getLocalScope();  // ??
@@ -651,7 +655,11 @@ public void run()
         {
             try
             {
-                if (!channel.isReadClosed())
+                if (channel.isReadAborted())
+                {
+                    handlerFuture.setSuccess();
+                }
+                else if (!channel.isReadClosed())
                 {
                     ZillaEngine engine = channel.engine;
                     int scopeIndex = channel.getLocalScope();