Package rx.internal.schedulers

Examples of rx.internal.schedulers.ScheduledAction.addParent()

102
103
104
105
106
107
108
109
110
111
112
                return Subscriptions.empty();
            }

            ScheduledAction s = poolWorker.scheduleActual(action, delayTime, unit);
            innerSubscription.add(s);
            s.addParent(innerSubscription);
            return s;
        }
    }

    private static final class PoolWorker extends NewThreadWorker {
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.