Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- var subject = new Subject<int>();
- //IDispose를 저장
- var disposable1 = subject.Subscribe(x => Debug.Log("스트림1:" + x), () => Debug.Log("OnCompleted"));
- var disposable2 = subject.Subscribe(x => Debug.Log("스트림2:" + x), () => Debug.Log("OnCompleted"));
- subject.OnNext(1);
- subject.OnNext(2);
- //스트림1 만 Subscribe 종료
- disposable1.Dispose();
- subject.OnNext(3);
- subject.OnCompleted();
- //---결과---//
- 스트림1:1
- 스트림2:1
- 스트림1:2
- 스트림2:2
- 스트림2:3 //스트림1:3 은 Dispose 로 인해 더이상 Subscribe 되지 않는다.
- 2.OnCompleted
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement