Java 类io.reactivex.subscribers.SerializedSubscriber 实例源码

@Override
protected void subscribeActual(Subscriber<? super T> s) {
    SerializedSubscriber<T> serial = new SerializedSubscriber<T>(s);
    if (fromStart) {
        source.subscribe(new TimeoutStartLast<T>(serial, timeout, unit, scheduler));
    } else {
        source.subscribe(new TimeoutLast<T>(serial, timeout, unit, scheduler.createWorker()));
    }
}

public void send(String tag, Object object) {
    EventObject eventObject = new EventObject(tag, object);
    new SerializedSubscriber<>(_bus).onNext(eventObject);
}

/**
 * 发送消息
 *
 * @param o
 */
public void post(Object o) {
    new SerializedSubscriber<>(mBus).onNext(o);
}