在 Flutter Redux Epic 中间件中，如何在流变量更改后分派操作？

Question

在 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 改变之后，但没有调度。是否可以在 Observable 更改后分派一个动作？

使用过的软件包：
redux_epics: ^0.10.0 & rxdart：^0.18.0

Answer 1

您必须 return observable/stream 才能调度操作

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())
    );
  });
}

在 Flutter Redux Epic 中间件中，如何在流变量更改后分派操作？

In Flutter Redux Epic middleware, how i can dispatch a action after the stream variable changes?

dart

redux

flutter

google-cloud-firestore

rxdart