AsyncSubject.subscribe

  1. Disposable subscribe(Observer!E observer)
  2. auto subscribe(T observer)
    class AsyncSubject(E)
    subscribe
    (
    T
    )