RxJava BehaviorSubjectが最後のアイテムを放出していませんか？

Question

私はReplaySubjectを使って簡単なRxJavaを持っていますが、3つの数字がすべて印刷された結果を得ることができました。

val observable : Observable<Int> = Observable.just(1, 2, 3) 
    val subject = ReplaySubject.create<Int>() 
    observable.subscribe(subject) 
    subject.subscribe{ 
     result -> 
     System.out.println("Start $result in Subscription Result") 
    } 

Iは動作に変更すると、私はいつも動作が最後に放出されたアイテムを再生することである考えとして、私は、第3の数即ち3が印刷されることを期待します。

val observable : Observable<Int> = Observable.just(1, 2, 3) 
    val subject = BehaviorSubject.create<Int>() 
    observable.subscribe(subject) 
    subject.subscribe{ 
     result -> 
     System.out.println("Start $result in Subscription Result") 
    } 

ただし、何も印刷されません。どうして？

ここで重要なことは忘れましたか？はいの場合は、最後に放出されたアイテム（つまり3）を印刷する方法を教えてください。

Answer 1

サブライセンスが既に終了しているため、何も印刷されません。サブスクリプションがまだアクティブである場合には3は、例えば、印刷される。

val o1: Observable<Int> = Observable.just(1, 2, 3) 
val o2: Observable<Int> = Observable.just(4).delay(100,TimeUnit.MILLISECONDS) 
val observable: Observable<Int> = Observable.concat(o1, o2) 
val subject = BehaviorSubject.create<Int>() 
observable.subscribe(subject) 
subject.subscribe{ 
    result -> 
    System.out.println("Start $result in Subscription Result") 
} 
Thread.sleep(1000) 

両方3及び4（遅延後）の後に放出される前に、サブスクリプション最新のイベントとして出射3及び4と、印刷されますサブスクリプション。さらにとしてコメントセクションReplaySubject.createWithSize(1)に@akarnokdによって説明

は常にさえ、観察終了後の最後の項目を再生すると、単一の項目に関係なく、ストリーム完了状態の必要があるならば、observable.takeLast(1).subscribe(subject)がそれを保証するために使用することができます使用することができます。

val observable : Observable<Int> = Observable.just(1, 2, 3) 
val subject = ReplaySubject.createWithSize<Int>(1) 
observable.takeLast(1).subscribe(subject) //can be moved after subject.subscribe as well 
subject.subscribe{ 
    result -> 
    System.out.println("Start $result in Subscription Result") 
}