|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 |
using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Drawing; using System.Linq; using System.Text; using System.Threading.Tasks; using System.Windows.Forms; namespace WindowsFormsApp1 { public class TestObserverDisposer : IDisposable { //監視対象を保持 public TestObservable observable; public TestObserverDisposer(TestObservable o) { this.observable = o; } public void Dispose() { observable.Observer = null; } } public class TestObservable : IObservable<int> { //監視側を保持 public TestObserver Observer; public void Excute() { if (Observer == null) return; Observer.OnNext(1); Observer.OnCompleted(); } public IDisposable Subscribe(IObserver<int> o) { Observer = (TestObserver)o; return new TestObserverDisposer(this); } } public class TestObserver : IObserver<int> { public void OnError(Exception e) { } public void OnCompleted() { } public void OnNext(int val) { MessageBox.Show(val.ToString()); } } public partial class Form1 : Form { public Form1() { InitializeComponent(); TestObserver observer = new TestObserver(); TestObservable observable = new TestObservable(); IDisposable disporser = observable.Subscribe(observer); observable.Excute(); disporser.Dispose(); observable.Excute(); } } } |