SubscriptionManager constructor

SubscriptionManager(
  1. SpacetimeDbConnection _connection, {
  2. OfflineStorage? offlineStorage,
})

Implementation

SubscriptionManager(this._connection, {OfflineStorage? offlineStorage}) {
  _optimisticState = OptimisticStateManager(cache);

  if (offlineStorage != null) {
    late ReducerCaller caller;
    _mutationSyncer = MutationSyncer(
      connection: _connection,
      storage: offlineStorage,
      optimisticState: _optimisticState,
      cache: cache,
      send:
          (name, args, {requestId}) =>
              caller.callWithBytes(name, args, requestId: requestId),
    );
    caller = ReducerCaller(
      _connection,
      offlineStorage: offlineStorage,
      mutationHandler: _mutationSyncer,
    );
    reducers = caller;
  } else {
    reducers = ReducerCaller(_connection);
  }

  _startListening();
  _startConnectionMonitoring();
}