rx.internal.schedulers

Class NewThreadWorker

    • Constructor Detail

      • NewThreadWorker

        public NewThreadWorker(ThreadFactory threadFactory)

    • Method Detail

      • schedule

        public Subscription schedule(Action0 action)
        Description copied from class: Scheduler.Worker
        Schedules an Action for execution.
        Specified by:
        schedule in class  Scheduler.Worker
        Parameters:
        action - Action to schedule
        Returns:
        a subscription to be able to unsubscribe the action (unschedule it if not executed)

      • schedule

        public Subscription schedule(Action0 action,
                             long delayTime,
                             TimeUnit unit)
        Description copied from class: Scheduler.Worker
        Schedules an Action for execution at some point in the future.

        Note to implementors: non-positive delayTime should be regarded as undelayed schedule, i.e., as if the Scheduler.Worker.schedule(rx.functions.Action0) was called.

        Specified by:
        schedule in class  Scheduler.Worker
        Parameters:
        action - the Action to schedule
        delayTime - time to wait before executing the action; non-positive values indicate an undelayed schedule
        unit - the time unit of delayTime
        Returns:
        a subscription to be able to unsubscribe the action (unschedule it if not executed)

      • scheduleActual

        public ScheduledAction scheduleActual(Action0 action,
                                      long delayTime,
                                      TimeUnit unit)
        Parameters:
        action -
        delayTime -
        unit -
        Returns:

      • unsubscribe

        public void unsubscribe()
        Description copied from interface: Subscription
        Stops the receipt of notifications on the Subscriber that was registered when this Subscription was received.

        This allows unregistering an Subscriber before it has finished receiving all events (i.e. before onCompleted is called).

      • isUnsubscribed

        public boolean isUnsubscribed()
        Description copied from interface: Subscription
        Indicates whether this Subscription is currently unsubscribed.
        Specified by:
        isUnsubscribed in interface  Subscription
        Returns:
        true if this Subscription is currently unsubscribed, false otherwise