5.4 ObservableSseEmitter的设计实现