File tree Expand file tree Collapse file tree 2 files changed +6
-12
lines changed Expand file tree Collapse file tree 2 files changed +6
-12
lines changed Original file line number Diff line number Diff line change 1+ ---
2+ ' @powersync/node ' : patch
3+ ---
4+
5+ Throw when database is used after being closed.
Original file line number Diff line number Diff line change @@ -92,22 +92,11 @@ export class WorkerConnectionPool extends BaseObserver<DBAdapterListener> implem
9292 const listeners = new WeakMap < EventListenerOrEventListenerObject , ( e : any ) => void > ( ) ;
9393
9494 const comlink = Comlink . wrap < AsyncDatabaseOpener > ( {
95- postMessage : ( message : any , transfer ?: any ) => {
96- console . log ( 'to worker' , message ) ;
97- return worker . postMessage ( message , transfer ) ;
98- } ,
95+ postMessage : worker . postMessage . bind ( worker ) ,
9996 addEventListener : ( type , listener ) => {
10097 let resolved : ( event : any ) => void =
10198 'handleEvent' in listener ? listener . handleEvent . bind ( listener ) : listener ;
10299
103- {
104- const original = resolved ;
105- resolved = ( event ) => {
106- console . log ( 'from worker' , event ) ;
107- return original ( event ) ;
108- } ;
109- }
110-
111100 // Comlink wants message events, but the message event on workers in Node returns the data only.
112101 if ( type === 'message' ) {
113102 const original = resolved ;
You can’t perform that action at this time.
0 commit comments