test_class.file: hystrix-core/src/test/java/com/netflix/hystrix/strategy/concurrency/HystrixContextSchedulerTest.java
test_class.identifier: HystrixContextSchedulerTest
test_case.body: @Test(timeout = 2500)
      public void testUnsubscribeWrappedScheduler() throws InterruptedException {
          Scheduler s = Schedulers.newThread();
          final AtomicBoolean interrupted = new AtomicBoolean();
          final CountDownLatch start = new CountDownLatch(1);
          final CountDownLatch end = new CountDownLatch(1);
  
          HystrixContextScheduler hcs = new HystrixContextScheduler(s);
  
          Scheduler.Worker w = hcs.createWorker();
          try {
              w.schedule(new Action0() {
                  @Override
                  public void call() {
                      start.countDown();
                      try {
                          try {
                              Thread.sleep(5000);
                          } catch (InterruptedException ex) {
                              interrupted.set(true);
                          }
                      } finally {
                          end.countDown();
                      }
                  }
              });
              
              start.await();
              
              w.unsubscribe();
              
              end.await();
              
              assertTrue(interrupted.get());
          } finally {
              w.unsubscribe();
          }
      }
test_case.class_method_signature: HystrixContextSchedulerTest.testUnsubscribeWrappedScheduler()
test_case.full_signature: @Test(timeout = 2500) public void testUnsubscribeWrappedScheduler()
test_case.identifier: testUnsubscribeWrappedScheduler
test_case.invocations: newThread createWorker schedule countDown sleep set countDown await unsubscribe await assertTrue get unsubscribe
test_case.modifiers: @Test(timeout = 2500) public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testUnsubscribeWrappedScheduler()
focal_class.declarator: concurrencyStrategy
focal_class.modifier: private final
focal_class.original_string: private final HystrixConcurrencyStrategy concurrencyStrategy;
focal_class.type: HystrixConcurrencyStrategy
focal_class.var_name: concurrencyStrategy
focal_class.declarator: actualScheduler
focal_class.modifier: private final
focal_class.original_string: private final Scheduler actualScheduler;
focal_class.type: Scheduler
focal_class.var_name: actualScheduler
focal_class.declarator: threadPool
focal_class.modifier: private final
focal_class.original_string: private final HystrixThreadPool threadPool;
focal_class.type: HystrixThreadPool
focal_class.var_name: threadPool
focal_class.file: hystrix-core/src/main/java/com/netflix/hystrix/strategy/concurrency/HystrixContextScheduler.java
focal_class.identifier: HystrixContextScheduler
focal_class.class_method_signature: HystrixContextScheduler.HystrixContextScheduler(Scheduler scheduler)
focal_class.full_signature: public  HystrixContextScheduler(Scheduler scheduler)
focal_class.identifier: HystrixContextScheduler
focal_class.modifiers: public
focal_class.parameters: (Scheduler scheduler)
focal_class.signature:  HystrixContextScheduler(Scheduler scheduler)
focal_class.class_method_signature: HystrixContextScheduler.HystrixContextScheduler(HystrixConcurrencyStrategy concurrencyStrategy, Scheduler scheduler)
focal_class.full_signature: public  HystrixContextScheduler(HystrixConcurrencyStrategy concurrencyStrategy, Scheduler scheduler)
focal_class.identifier: HystrixContextScheduler
focal_class.modifiers: public
focal_class.parameters: (HystrixConcurrencyStrategy concurrencyStrategy, Scheduler scheduler)
focal_class.signature:  HystrixContextScheduler(HystrixConcurrencyStrategy concurrencyStrategy, Scheduler scheduler)
focal_class.class_method_signature: HystrixContextScheduler.HystrixContextScheduler(HystrixConcurrencyStrategy concurrencyStrategy, HystrixThreadPool threadPool)
focal_class.full_signature: public  HystrixContextScheduler(HystrixConcurrencyStrategy concurrencyStrategy, HystrixThreadPool threadPool)
focal_class.identifier: HystrixContextScheduler
focal_class.modifiers: public
focal_class.parameters: (HystrixConcurrencyStrategy concurrencyStrategy, HystrixThreadPool threadPool)
focal_class.signature:  HystrixContextScheduler(HystrixConcurrencyStrategy concurrencyStrategy, HystrixThreadPool threadPool)
focal_class.class_method_signature: HystrixContextScheduler.HystrixContextScheduler(HystrixConcurrencyStrategy concurrencyStrategy, HystrixThreadPool threadPool, Func0<Boolean> shouldInterruptThread)
focal_class.full_signature: public  HystrixContextScheduler(HystrixConcurrencyStrategy concurrencyStrategy, HystrixThreadPool threadPool, Func0<Boolean> shouldInterruptThread)
focal_class.identifier: HystrixContextScheduler
focal_class.modifiers: public
focal_class.parameters: (HystrixConcurrencyStrategy concurrencyStrategy, HystrixThreadPool threadPool, Func0<Boolean> shouldInterruptThread)
focal_class.signature:  HystrixContextScheduler(HystrixConcurrencyStrategy concurrencyStrategy, HystrixThreadPool threadPool, Func0<Boolean> shouldInterruptThread)
focal_class.class_method_signature: HystrixContextScheduler.createWorker()
focal_class.full_signature: @Override public Worker createWorker()
focal_class.identifier: createWorker
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: Worker
focal_class.signature: Worker createWorker()
focal_class.superclass: extends Scheduler
focal_method.body: @Override
      public Worker createWorker() {
          return new HystrixContextSchedulerWorker(actualScheduler.createWorker());
      }
focal_method.class_method_signature: HystrixContextScheduler.createWorker()
focal_method.full_signature: @Override public Worker createWorker()
focal_method.identifier: createWorker
focal_method.invocations: createWorker
focal_method.modifiers: @Override public
focal_method.parameters: ()
focal_method.return: Worker
focal_method.signature: Worker createWorker()