Angular 和 rxJS。流永远不会完成

我在 angular 应用程序中有一个菜单，这个菜单控制我的 Web 应用程序中选定的客户端。

因为它是：

• 我的菜单是一个组件，它通过服务共享选定的客户端。
• 选定的客户端作为 Observable 共享。
• 可观察对象永远不会完成。单击菜单时，它只会发出新的选定客户端。
• 这是一个重播主题。每个新订阅者检索最后发出的客户端。

这似乎是一个不错的设计，但是在基于客户端创建新的 observables 时我遇到了一些问题（从未完成 observables）。AFAIK 这是由于第一个 observable 永远不会完成并且此属性将传播。

//Command
export interface Command {
    productName: string;
    qty: number;
}

//The service
@Injectable()
export class ClientService {
private _client: ReplaySubject<Client> = new ReplaySubject(1);

    setClient(client: Client) { // The menu component calls setClient on a user click
        this._client.next(client);
    }
    getClient(): Observable<Client> { // getClient is heavilly called in child component to observe client selection events.
        return this._client.asObservable();
    }
}


getCommands(): Observable<Command> { //Used in a template with async pipe

    //In a child component
    const commandsObs = this.clientService.getClient()
    //.take(1) //I am forced to use take(1) to get getCommands() observer to complete
    .flatMap(c => {
        return Observable.merge(getCommandsPromise1(c), getCommandsPromise2(c));
    })
    .reduce((acc, next) => Object.assign({}, acc, next))
    .map(next => {
        return finishMakingCommand(next));
    })
    .catch(err => /* Some error management code*/)
}

getCommandsPromise1(client: Client): Promise<any> {
    //REST call returning a promise
    return Promise.resolve({ 'command1': { 'productName': 'toy', qty: 1 } });
}
getCommandsPromise2(client: Client): Promise<any> {
    //REST call returning a promise
    return Promise.resolve({ 'command2': { 'productName': 'another toy', qty: 1 } });
}

finishMakingCommand(commands: any): Command[] {
    // Flattens 'command1' and 'command2' to a list of commands
    return [{'productName': 'toy', qty: 1}, {'productName': 'another toy', qty: 2}];
}

我想知道更有经验的开发人员是否认为永无止境的 observable 是一个好的设计，以及有哪些替代方案可以避免永无止境的 observables。