@@ -23,7 +23,12 @@ import {
2323 type SubscriptionEventContextInterface ,
2424} from './event_context.ts' ;
2525import { EventEmitter } from './event_emitter.ts' ;
26- import type { Deserializer , Identity , InferTypeOfRow , Serializer } from '../' ;
26+ import type {
27+ Deserializer ,
28+ Identity ,
29+ InferTypeOfParams ,
30+ Serializer ,
31+ } from '../' ;
2732import type {
2833 ProcedureResultMessage ,
2934 ReducerResultMessage ,
@@ -383,7 +388,9 @@ export class DbConnectionImpl<RemoteModule extends UntypedRemoteModule>
383388 const { serialize : serializeArgs } =
384389 this . #reducerArgsSerializers[ reducerName ] ;
385390
386- ( out as any ) [ key ] = ( params : InferTypeOfRow < typeof reducer . params > ) => {
391+ ( out as any ) [ key ] = (
392+ params : InferTypeOfParams < typeof reducer . params >
393+ ) => {
387394 const writer = this . #reducerArgsEncoder;
388395 writer . clear ( ) ;
389396 serializeArgs ( writer , params ) ;
@@ -414,7 +421,7 @@ export class DbConnectionImpl<RemoteModule extends UntypedRemoteModule>
414421 this . #procedureSerializers[ procedureName ] ;
415422
416423 ( out as any ) [ key ] = (
417- params : InferTypeOfRow < typeof procedure . params >
424+ params : InferTypeOfParams < typeof procedure . params >
418425 ) : Promise < any > => {
419426 writer . clear ( ) ;
420427 serializeArgs ( writer , params ) ;
@@ -436,7 +443,7 @@ export class DbConnectionImpl<RemoteModule extends UntypedRemoteModule>
436443 event : Event <
437444 ReducerEventInfo <
438445 RemoteModule [ 'reducers' ] [ number ] [ 'name' ] ,
439- InferTypeOfRow < RemoteModule [ 'reducers' ] [ number ] [ 'params' ] >
446+ InferTypeOfParams < RemoteModule [ 'reducers' ] [ number ] [ 'params' ] >
440447 >
441448 >
442449 ) : EventContextInterface < RemoteModule > {
0 commit comments