File tree Expand file tree Collapse file tree
PowerSync/PowerSync.Common Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -106,7 +106,7 @@ public interface IBucketStorageEvent;
106106
107107 public class CrudUpdateEvent : IBucketStorageEvent ;
108108
109- public EventStream< CrudUpdateEvent > OnCrudUpdate = new ( ) ;
109+ public EventStream< CrudUpdateEvent > OnCrudUpdate { get ; } = new ( ) ;
110110
111111 public BucketStorageEvents ( )
112112 {
Original file line number Diff line number Diff line change @@ -91,12 +91,12 @@ public class DBAdapterEvents : EventManager
9191{
9292 public interface IDBAdapterEvent ;
9393
94- public class TablesUpdatedEvent ( INotification tablesUpdatedNotification )
94+ public class TablesUpdatedEvent ( INotification tablesUpdatedNotification ) : IDBAdapterEvent
9595 {
9696 public INotification TablesUpdated { get ; set ; } = tablesUpdatedNotification ;
9797 }
9898
99- public EventStream < TablesUpdatedEvent > OnTablesUpdated = new ( ) ;
99+ public EventStream < TablesUpdatedEvent > OnTablesUpdated { get ; } = new ( ) ;
100100
101101 public DBAdapterEvents ( )
102102 {
Original file line number Diff line number Diff line change @@ -137,11 +137,11 @@ protected virtual void LoadExtension(SqliteConnection db)
137137
138138 public void Close ( )
139139 {
140- Events . Close ( ) ;
141140 tablesUpdatedCts ? . Cancel ( ) ;
142141 try { tablesUpdatedTask ? . Wait ( TimeSpan . FromSeconds ( 2 ) ) ; } catch { }
143142 writeConnection ? . Close ( ) ;
144143 readConnection ? . Close ( ) ;
144+ Events . Close ( ) ;
145145 }
146146
147147 public async Task < NonQueryResult > Execute ( string query , object ? [ ] ? parameters = null )
You can’t perform that action at this time.
0 commit comments