Introduce plumbing for ObservablesReducer