diff --git a/bench/stream-readable.mjs b/bench/stream-readable.mjs
index 38065ee9..be8cefa8 100644
--- a/bench/stream-readable.mjs
+++ b/bench/stream-readable.mjs
@@ -1,6 +1,7 @@
 import { skipIfVersion } from '../utils.mjs'
 import { Readable } from 'node:stream'
 import { ReadableStream } from 'node:stream/web'
+import assert from 'node:assert'
 import { createBenchmarkSuite } from '../common.mjs'
 
 skipIfVersion('<= 16.5.0')
@@ -8,49 +9,37 @@ skipIfVersion('<= 16.5.0')
 const suite = createBenchmarkSuite('Stream.Readable')
 
 suite
-  .add('streams.Readable reading 1e3 * "some data"', {
-    defer: true,
-    fn: async function (deferred) {
-      function* readImpl(_sizeT) {
-        let i = 0
-        while (i < 1e3) {
-          yield 'some data'
-          ++i
-        }
+  .add('streams.Readable reading 1e3 * "some data"', async () => {
+    function* readImpl(_sizeT) {
+      let i = 0
+      while (i < 1e3) {
+        yield 'some data'
+        ++i
       }
-      const readable = Readable.from(readImpl())
+    }
+    const readable = Readable.from(readImpl())
 
-      try {
-        for await (const _ of readable) {
+    for await (const _ of readable) {
+      assert.ok(_)
+    }
+  },
+  )
+  .add('streams.web.Readable reading 1e3 * "some data"', async () => {
+    let i = 0
+    const readable = new ReadableStream({
+      pull: function (controller) {
+        controller.enqueue('some data')
+        ++i
+        if (i >= 1e3) {
+          controller.close()
         }
-        deferred.resolve()
-      } catch (e) {
-        deferred.reject(e)
-      }
-    },
-  })
-  .add('streams.web.Readable reading 1e3 * "some data"', {
-    defer: true,
-    fn: async function (deferred) {
-      let i = 0
-      const readable = new ReadableStream({
-        pull: function (controller) {
-          controller.enqueue('some data')
-          ++i
-          if (i >= 1e3) {
-            controller.close()
-          }
-        },
-      })
+      },
+    })
 
-      try {
-        for await (const _ of readable) {
-        }
-        deferred.resolve()
-      } catch (e) {
-        deferred.reject(e)
-      }
-    },
-  })
+    for await (const _ of readable) {
+      assert.ok(_)
+    }
+  },
+  )
 
 await suite.runAndPrintResults()