IObservable의 BehaviorSubject 동작

Question

IObservable에서 BehaviorSubject과 동일한 동작을 얻으려고합니다.

내가 .Take(1)을 수행 할 때 기본 IObservable이 변경 될 때까지 "기본값"을 반환하고 싶습니다. 기초가되는 IObservable은 "펌프질"을 한 번 완료하고 완료됩니다.

나는 이것이 나쁜 형태라고 생각하므로 실제로는 BehaviorSubject을 사용하고 싶지 않습니다 (이 경우는 간단합니다).

이것이 가능합니까?

Answer 1

항상 초기 값을 갖는 스트림을 원하면 .StartWith() 방법을 사용하는 것이 좋습니다.

후드 아래에서는 .TakeUntil()이없는 경우를 제외하고 Lee의 답변과 매우 유사한 기능을 수행합니다.

구독자가 마지막 값을 즉시 수신하도록하려면이 값을 .Replay(1)과 결합해야 할 수 있습니다.

Answer 2

public static IObservable<T> Behaviour<T>(IObservable<T> source) 
{ 
    return Observable.Return(default(T)).TakeUntil(source).Concat(source); 
}