2

Flutter Redux Epic ミドルウェアでは、ストリーム変数の変更後にアクションをディスパッチするにはどうすればよいですか?

EpicMiddleware の簡単な例:

final allEpics = combineEpics<AppState>([hourglassesStream]);

Firestore firestore = Firestore.instance;


Stream<dynamic> hourglassesStream(
    Stream<dynamic> actions, EpicStore<AppState> store) {
  return Observable(actions)
      .ofType(TypeToken<ConnectToDataSourceAction>())
      .switchMap((ConnectToDataSourceAction requestAction) {
    getHourglasses(action.userId).listen((hourglass) {

      LoadHourglassesHistoryAction(
          hourglass.map(Hourglass.fromEntity).toList());
    });
  });
}

Observable<List<HourglassEntity>> getHourglasses(String userId) {
  return Observable(firestore
      .collection('users')
      .document(userId)
      .collection('hourglassLogs')
      .snapshots()
      .map((snapshot) {
    return snapshot.documents.map((doc) {
      return HourglassEntity(
        doc['completedTime'],
        doc['projectName'],
        doc['userId'],
      );
    }).toList();
  }));
}

砂時計変数が監視可能から変更された後、このLoadHourglassesHistoryActionをディスパッチするためにいくつかの異なる方法を試しましたが、ディスパッチしませんでした。Observable の変更後にアクションをディスパッチすることは可能ですか?

使用パッケージ:
redux_epics: ^0.10.0 & rxdart: ^0.18.0

4

1 に答える 1

2

アクションをディスパッチするには、オブザーバブル/ストリームを返す必要があります

Stream<dynamic> hourglassesStream(
    Stream<dynamic> actions, EpicStore<AppState> store) {
  return Observable(actions)
      .ofType(TypeToken<ConnectToDataSourceAction>())
      .switchMap((ConnectToDataSourceAction requestAction) {
    return getHourglasses(action.id).map((hourglass) =>
     LoadHourglassesHistoryAction(
          hourglass.map(Hourglass.fromEntity).toList())
    );
  });
}
于 2018-09-30T16:18:11.767 に答える