T
public interface BasicEmitter<T>
void
doComplete()
doError(Throwable t)
doNext(T t)
void doNext(T t)
void doError(Throwable t)
void doComplete()