使用 ngrx.store 和 states 时,我遇到了一个错误(?)。
在我发送新状态并且减速器返回新状态之后,什么都没有发生。订阅不会收到任何错误消息。 如果我删除 switchMap,代码会起作用,并且订阅者会得到他应该得到的值。
我尽可能地最小化了我的代码:
public a$:Observable<any>;
constructor(private _userService:UserService, private _store:Store<any>)
{
this.a$=this._store
.select(state=>state)
.switchMap(state=>
{
return Observable.from(["1"]); //for simplicity.
});
this.a$.subscribe(
something=>{
console.log(something);
},
error=>{
console.log(error);
}
);
}
我的减速机:
export const connectedUserReducer = (state = initialState, action:Action) =>
{
if(action==null || action.type==null)
return state;
switch (action.type) {
case updateConnectedUser:
return Object.assign({},state); <<<-- It comes here and then nothing heppends.<<--
default:
return state;
}
};
我确实将 switchMap 导入为:“import 'rxjs/add/operator/switchMap';”