diff --git a/lib/base/prepared-statement.js b/lib/base/prepared-statement.js
index b88967a8..02a0bea3 100644
--- a/lib/base/prepared-statement.js
+++ b/lib/base/prepared-statement.js
@@ -356,11 +356,10 @@ class PreparedStatement extends EventEmitter {
       }
     }
 
-    req.execute('sp_execute', (err, result) => {
-      if (err) return callback(err)
-
-      callback(null, result)
-    })
+    req.execute('sp_execute', typeof callback === 'function'
+      ? callback
+      : () => {}
+    )
 
     return req
   }
diff --git a/test/common/tests.js b/test/common/tests.js
index 73810c31..3a56335d 100644
--- a/test/common/tests.js
+++ b/test/common/tests.js
@@ -907,6 +907,26 @@ module.exports = (sql, driver) => {
       }).catch(done)
     },
 
+    'prepared statement with streaming and no callback' (done) {
+      const ps = new TestPreparedStatement()
+      ps.stream = true
+      ps.input('num', sql.Int)
+      ps.prepare('select @num as number').then(() => {
+        const req = ps.execute({ num: 123 })
+        const rows = []
+
+        req.on('row', row => rows.push(row))
+        req.on('error', err => {
+          ps.unprepare(() => done(err))
+        })
+        req.on('done', () => {
+          assert.strictEqual(rows.length, 1)
+          assert.strictEqual(rows[0].number, 123)
+          ps.unprepare(done)
+        })
+      }).catch(done)
+    },
+
     'transaction with rollback' (done) {
       let tbegin = false
       let tcommit = false
diff --git a/test/common/unit.js b/test/common/unit.js
index 4757c253..eed4fe83 100644
--- a/test/common/unit.js
+++ b/test/common/unit.js
@@ -1402,4 +1402,24 @@ describe('connection string auth - tedious', () => {
       })
     })
   })
+
+  describe('PreparedStatement streaming', () => {
+    const BasePreparedStatement = require('../../lib/base/prepared-statement')
+    const ConnectionPool = require('../../lib/tedious/connection-pool')
+
+    it('execute does not throw when stream=true and no callback provided', (done) => {
+      const pool = new ConnectionPool({ server: 'localhost' })
+      const ps = new BasePreparedStatement(pool)
+      ps.stream = true
+      ps.prepared = true
+      ps._handle = 1
+
+      // Should not throw TypeError — returns the inner Request
+      const req = ps.execute({})
+      assert.ok(req, 'execute() should return the inner Request')
+      // The request will error (no connection) — that's fine,
+      // the point is it doesn't throw TypeError
+      req.on('error', () => done())
+    })
+  })
 })
diff --git a/test/msnodesqlv8/msnodesqlv8.js b/test/msnodesqlv8/msnodesqlv8.js
index 8963a3db..6020f0a6 100644
--- a/test/msnodesqlv8/msnodesqlv8.js
+++ b/test/msnodesqlv8/msnodesqlv8.js
@@ -81,6 +81,7 @@ describe('msnodesqlv8', function () {
     it('prepared statement with affected rows', done => TESTS['prepared statement with affected rows'](done))
     it('prepared statement in transaction', done => TESTS['prepared statement in transaction'](done))
     it('prepared statement with duplicate output column names', done => TESTS['prepared statement with duplicate output column names'](done))
+    it('prepared statement with streaming and no callback', done => TESTS['prepared statement with streaming and no callback'](done))
     it('transaction with rollback', done => TESTS['transaction with rollback'](done))
     it('transaction with commit', done => TESTS['transaction with commit'](done))
     it('transaction throws on bad isolation level', done => TESTS['transaction throws on bad isolation level'](done))
diff --git a/test/tedious/tedious.js b/test/tedious/tedious.js
index e99fa9f5..c7655af0 100644
--- a/test/tedious/tedious.js
+++ b/test/tedious/tedious.js
@@ -88,6 +88,7 @@ describe('tedious', () => {
     it('prepared statement with affected rows', done => TESTS['prepared statement with affected rows'](done))
     it('prepared statement in transaction', done => TESTS['prepared statement in transaction'](done))
     it('prepared statement with duplicate output column names', done => TESTS['prepared statement with duplicate output column names'](done))
+    it('prepared statement with streaming and no callback', done => TESTS['prepared statement with streaming and no callback'](done))
     it('transaction with rollback', done => TESTS['transaction with rollback'](done))
     it('transaction with commit', done => TESTS['transaction with commit'](done))
     it('transaction throws on bad isolation level', done => TESTS['transaction throws on bad isolation level'](done))