...

Author: igalklebanov

src/kysely.ts

@@ -51,7 +51,6 @@ import {
   provideControlledConnection,
 } from './util/provide-controlled-connection.js'
 import { ConnectionProvider } from './driver/connection-provider.js'
-import { logOnce } from './util/log-once.js'
 import { ExecuteOptions } from './util/executable.js'
 
 // @ts-ignore
@@ -1185,9 +1184,10 @@ class NotCommittedOrRolledBackAssertingExecutor implements QueryExecutor {
   stream<R>(
     compiledQuery: CompiledQuery<R>,
     chunkSize: number,
+    options?: ExecuteQueryOptions,
   ): AsyncIterableIterator<QueryResult<R>> {
     assertNotCommittedOrRolledBack(this.#state)
-    return this.#executor.stream(compiledQuery, chunkSize)
+    return this.#executor.stream(compiledQuery, chunkSize, options)
   }
 
   withConnectionProvider(