Observableを使用したクラス間の通知

Question

私は、サーバーからのユーザーのリストを持つクラスを持っています。
他のクラスでは、サーバー上のリストを操作できます。追加または削除操作を呼び出します。
My Core-Classには、サーバー上のリストを操作している他のクラスへの参照があります。

私はしたいと思います：

• はコアクラスは、プラグインによって、リストが上で操作されたたびに通知されます
• 最初にリストを取得するには、コア・クラスでのinitの呼び出しを行いますサーバであるため、Core-Classはサーバから再度リストを取得します。
• リストがリロードされたことを他のクラスに通知し、新しいリストを転送します。

マイ構造

Core { 

    users: []; 

    plugin1: Plugin; 
    plugin2: Plugin; 

    //Get a new list of users from the server 
    loadUsers() { 
     userService.loadUsers.then(function (res) { 
     this.users = res; 
     }) 
    } 

    } 

    Plugin { 

    //sends a request to the server to create a special user, 
    //depending on plugin implementation 
    createUser(); 
    } 

私はちょうどRXを使用するのでは始めています。私は工場の方法、暑い対寒い観察可能な他の基本的なものを理解しています。しかし、私は正しい方法でrxでそれをする方法を想像することはできません。

ありがとうございました。反応実装の

Answer 1

私の考えは次のようになります。あなたのUserServiceので

は、次の行を追加します。

var loadSubject = new Subject(); 
var usersObservable = loadSubject.flatMap(
    Observable.fromPromise(<your http call that returns promise>)).share() 

function loadUsers(){ 
    loadSubject.next(true); 
} 

その後、変更を加えた各プラグインは、単に呼び出します。

userService.loadUsers(); 

あなたのコア、プラグイン、および更新したい他のクラスは、単に次のようにします：

loadService.usersObservable.subscribe(function(usersFreshValue){ 
    this.users = usersFreshValue; 
}) 

データの重複を避けるために '.share（）'を使用しました。

考えられる改善：代わりにloadUsers方法の

1. は、各プラグインはuserService.loadSubject.next（true）を呼び出す持っています。

2. バックプレッシャ/バッファリング演算子を使用して、頻繁にコールすることを避けます。例えば、デバウンス（注意：誤って使用すると飢餓の原因となる可能性があります）またはbufferWithTime +フィルタ（空のバッファでトリガーしないようにする）などです。値。