OperatorTimeoutBase.java 文件源码

private TimeoutSubscriber(
        SerializedSubscriber<T> serializedSubscriber,
        TimeoutStub<T> timeoutStub, SerialSubscription serial,
        Observable<? extends T> other,
        Scheduler.Worker inner) {
    super(serializedSubscriber);
    this.serializedSubscriber = serializedSubscriber;
    this.timeoutStub = timeoutStub;
    this.serial = serial;
    this.other = other;
    this.inner = inner;
}