Package com.netflix.hystrix.strategy.concurrency

Class HystrixContextScheduler

java.lang.Object

rx.Scheduler

com.netflix.hystrix.strategy.concurrency.HystrixContextScheduler

public class HystrixContextScheduler
extends rx.Scheduler

Wrap a Scheduler so that scheduled actions are wrapped with HystrixContexSchedulerAction so that the HystrixRequestContext is properly copied across threads (if they are used by the Scheduler).

Nested Class Summary

Nested classes/interfaces inherited from class rx.Scheduler

rx.Scheduler.Worker

Constructor Summary

Constructors

Constructor and Description
HystrixContextScheduler(HystrixConcurrencyStrategy concurrencyStrategy, HystrixThreadPool threadPool)
HystrixContextScheduler(HystrixConcurrencyStrategy concurrencyStrategy, HystrixThreadPool threadPool, rx.functions.Func0<java.lang.Boolean> shouldInterruptThread)
HystrixContextScheduler(HystrixConcurrencyStrategy concurrencyStrategy, rx.Scheduler scheduler)
HystrixContextScheduler(rx.Scheduler scheduler)

Method Summary

Modifier and Type	Method and Description
rx.Scheduler.Worker	createWorker()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from class rx.Scheduler

now

Constructor Detail

HystrixContextScheduler

public HystrixContextScheduler(HystrixConcurrencyStrategy concurrencyStrategy,
                               HystrixThreadPool threadPool)

HystrixContextScheduler

public HystrixContextScheduler(HystrixConcurrencyStrategy concurrencyStrategy,
                               HystrixThreadPool threadPool,
                               rx.functions.Func0<java.lang.Boolean> shouldInterruptThread)

HystrixContextScheduler

public HystrixContextScheduler(HystrixConcurrencyStrategy concurrencyStrategy,
                               rx.Scheduler scheduler)

HystrixContextScheduler

public HystrixContextScheduler(rx.Scheduler scheduler)

Method Detail

createWorker

public rx.Scheduler.Worker createWorker()

Specified by:

createWorker in class rx.Scheduler