源码类别
热门源码
 当前位置：源码 > Java源码 >

Java源码示例：rx.internal.schedulers.ScheduledAction

示例1
@Override
public Subscription schedule(Action0 action) {
  if (isUnsubscribed()) {
    return Subscriptions.unsubscribed();
  }
  ScheduledAction s = poolWorker.scheduleActual(action, 0, null, serial);

  return s;
}
示例2
@Override
public Subscription schedule(Action0 action, long delayTime, TimeUnit unit) {
  if (isUnsubscribed()) {
    return Subscriptions.unsubscribed();
  }
  ScheduledAction s = poolWorker.scheduleActual(action, delayTime, unit, timed);

  return s;
}
示例3
@Override
public Subscription schedule(Action0 action, long delayTime, TimeUnit unit) {
    if (innerSubscription.isUnsubscribed()) {
        // don't schedule, we are unsubscribed
        return Subscriptions.empty();
    }
    
    ScheduledAction s = (ScheduledAction)innerWorker.schedule(action, delayTime, unit);
    innerSubscription.add(s);
    s.addParent(innerSubscription);
    return s;
}
示例4
@Override
public Subscription schedule(Action0 action) {
    if (isUnsubscribed()) {
        return Subscriptions.unsubscribed();
    }
    ScheduledAction s = poolWorker.scheduleActual(action, 0, null, serial);

    return s;
}
示例5
@Override
public Subscription schedule(Action0 action, long delayTime, TimeUnit unit) {
    if (isUnsubscribed()) {
        return Subscriptions.unsubscribed();
    }
    ScheduledAction s = poolWorker.scheduleActual(action, delayTime, unit, timed);

    return s;
}
示例6
@Override
public Subscription schedule(Action0 action, long delayTime, TimeUnit unit) {
    if (innerSubscription.isUnsubscribed()) {
        // don't schedule, we are unsubscribed
        return Subscriptions.empty();
    }
    
    ScheduledAction s = (ScheduledAction)innerWorker.schedule(action, delayTime, unit);
    innerSubscription.add(s);
    s.addParent(innerSubscription);
    return s;
}