SatelliteProcess constructor

SatelliteProcess({
  1. required DbName dbName,
  2. required Client client,
  3. required SatelliteOpts opts,
  4. required DatabaseAdapter adapter,
  5. required Migrator migrator,
  6. required Notifier notifier,
})

Implementation

SatelliteProcess({
  required this.dbName,
  required this.client,
  required this.opts,
  required DatabaseAdapter adapter,
  required this.migrator,
  required this.notifier,
})  : _adapter = adapter,
      builder = migrator.queryBuilder {
  subscriptionManager = ShapeManager(
    onShapeSyncStatusUpdated: (key, status) =>
        notifier.shapeSubscriptionSyncStatusChanged(dbName, key, status),
  );

  throttledSnapshot = Throttle(
    mutexSnapshot,
    opts.minSnapshotWindow,
  );

  connectRetryHandler = defaultConnectRetryHandler;
}