RxJava Observable、emit on demand

Question

私のAndroidアプリケーションでは、ユーザーの写真のリストを表示します。写真はサーバー上に保存され、写真の量は非常に多くなることがあります。ユーザーが写真を表示するように要求すると、アプリケーションはサーバーから最初に、例えば10枚の写真を取得します。ユーザーは次に10を表示するように頼み、アプリケーションはさらに10をロードします。 私はrx.Observableを使って写真を読み込み、それぞれを加入者のonNext（）で表示します。 しかし、どのように私はObservable、と言うことができると写真をサーバーからプルするには？使用プロデューサー -

---

は ソリューションを発見しました。プロデューサーについては good articleです

Answer 1

私のおかげで、C＃になりました（うまくいけば誰かが私のために翻訳できる）。

あなたはこれを試みることができる：

var subject = new Subject<int>(); 

var query = 
    from count in subject 
    from image in GetImages(count) 
    select image; 

query 
    .Subscribe(image => 
    { 
     /* do something with each image */ 
    }); 

は、あなたは自分のGetImagesメソッドを定義する必要があります。

ここで、このコードを呼び出す場合は、画像を10個取得するときにsubject.OnNext(10)を実行してください。