flutter - 放大数据存储 : How to know when sync is finished?

Question

我们如何知道 DataStore 已完成同步？

当用户登录后执行第一次 await DataStore.query(MyEntity) 时，DataStore 会立即返回，而不是等待数据与云端同步。

我想等待同步完成，并在数据尚未同步时加载。

Answer 1

您可以使用 Amplify.Hub.listen 监听数据存储 channel 上的事件。

详情:

 subscription = Amplify.Hub.listen([HubChannel.DataStore], (dynamic hubEvent) async {
      switch (hubEvent.eventName) {
        case 'networkStatus':
          _amplifyIsUp.value = hubEvent.payload.active;
          break;
        case 'subscriptionsEstablished':
          _amplifyMessage.value = 'Starting to sync from cloud...';
          break;
        case 'syncQueriesStarted':
          _amplifyIsSyncing.value = true;
          _amplifyMessage.value = 'Syncing...';
          break;
        case 'modelSynced':
          ModelSyncedEvent mse = hubEvent.payload;

          _amplifyMessage.value = '${mse.modelName} has been sync\'d from cloud...';
          break;
        case 'syncQueriesReady':
          _amplifyMessage.value = 'Done!';
          _amplifyIsSyncing.value = false;
          
          ///do your bits here
          onSyncsReady.call();
          
          break;
        case 'ready':
          _amplifyIsSyncing.value = false;

          break;
        case 'subscriptionDataProcessed':
   
          SubscriptionDataProcessedEvent sdpe = hubEvent.payload;
                  _amplifyMessage.value = 'Syncing ${sdpe.element.model.classType.modelName()}...';
         if (sdpe.element.model is DeviceStatus) {
            DeviceStatus ds = sdpe.element.model as DeviceStatus;
            if (ds.clientID == _clientService.client.id && ds.status == Status.REQUESTSTATUS) {
              _statusService.performHeartbeat();
              } 
          }
          break;
        case 'outboxMutationEnqueued':
          _amplifyIsSyncing.value = true;
          _amplifyHasDirt.value = true;
          break;
        case 'outboxMutationProcessed':
          OutboxMutationEvent ome = hubEvent.payload;
          _amplifyIsSyncing.value = false;
          break;
        case 'outboxStatus':
          OutboxStatusEvent ose = hubEvent.payload;
          if (ose.isEmpty) {
            _amplifyIsSyncing.value = false;
            _amplifyHasDirt.value = false;
          } else {
            _amplifyHasDirt.value = true;
          }

          break;
      }
    });

嘘