填充可观察流

-1

使用Observable，我想用连接的用户填充流。填充可观察流

在一本书，我读了其中为例非常类似于下面的代码：

import {Injectable} from '@angular/core'; 
import {Subject, BehaviorSubject, Observable} from 'rxjs'; 
import {User} from "./user"; 
import {IUserService} from "./IUserService"; 

let initialConnectedUsers: User[] = []; 
interface IUsersOperation extends Function { 
    (users: User[]): User[]; 
} 

@Injectable() 
export class UserService implements IUserService{ 
    currentUser: Subject<User> = new BehaviorSubject<User>(null); 

    newUser: Subject<User> = new Subject<User>(); 
    connectedUsers: Observable<User[]>; 

    updates: Subject<any> = new Subject<any>(); 
    create: Subject<User> = new Subject<User>(); 

    constructor(){ 
     this.connectedUsers = this.updates 
      .scan((users: User[], operation: IUsersOperation) => { 
        return operation(users); 
       }, 
       initialConnectedUsers) 
      .publishReplay(1) 
      .refCount(); 

     this.create.map(function (user: User): IUsersOperation { 
      return (users: User[]) => { 
       console.log('foo'); 
       return users.concat(user); 
      } 
     }).subscribe(this.updates); 

     this.newUser.subscribe(this.create); 
    } 

    public setCurrentUser(newUser: User): void { 
     this.currentUser.next(newUser); 
     this.newUser.next(newUser); 
    } 
} 

export var userServiceInjectables: Array<any> = [ 
    UserService 
];

但在我的情况下，可观察到“创造”不用，我没有看到控制台日志。

来源

2017-01-08 mickaelw

是什么*“在我的情况下，可观察到‘创造’不使用” *是什么意思？ – martin

你可以在这里阅读（https://github.com/ng-book/angular2-rxjs-chat/blob/master/app/ts/services/MessagesService.ts）代码是什么启发了我。在那个代码中，connectedUsers的等价物被填充了observables创建和更新 – mickaelw

在应用程序的初始化（用于为例：app.component.ts）我写这篇文章的代码：

this.userService.connectedUsers.subscribe(() => ({}));

来源

2017-01-08 20:29:51 mickaelw

填充可观察流

回答

相关问题