,-------------------.
,---------------------.  |IObserver          |
|IObservable          |  |-------------------|
|---------------------|  |OnNext(T);         |
|Subscribe(IObserver);|--|OnError(Exception);|
`---------------------'  |OnCompleted();     |
                         `-------------------'