test_class.declarator: commandKey = HystrixCommandKey.Factory.asKey("COMMAND")
test_class.modifier: static final
test_class.original_string: static final HystrixCommandKey commandKey = HystrixCommandKey.Factory.asKey("COMMAND");
test_class.type: HystrixCommandKey
test_class.var_name: commandKey
test_class.declarator: threadPoolKey = HystrixThreadPoolKey.Factory.asKey("ThreadPool")
test_class.modifier: static final
test_class.original_string: static final HystrixThreadPoolKey threadPoolKey = HystrixThreadPoolKey.Factory.asKey("ThreadPool");
test_class.type: HystrixThreadPoolKey
test_class.var_name: threadPoolKey
test_class.declarator: commandStream = new HystrixCommandCompletionStream(commandKey)
test_class.modifier: final
test_class.original_string: final HystrixCommandCompletionStream commandStream = new HystrixCommandCompletionStream(commandKey);
test_class.type: HystrixCommandCompletionStream
test_class.var_name: commandStream
test_class.file: hystrix-core/src/test/java/com/netflix/hystrix/metric/HystrixCommandCompletionStreamTest.java
test_class.identifier: HystrixCommandCompletionStreamTest
test_case.body: @Test
      public void noEvents() throws InterruptedException {
          CountDownLatch latch = new CountDownLatch(1);
          Subscriber<HystrixCommandCompletion> subscriber = getLatchedSubscriber(latch);
  
          commandStream.observe().take(1).subscribe(subscriber);
  
          //no writes
  
          assertFalse(latch.await(1000, TimeUnit.MILLISECONDS));
      }
test_case.class_method_signature: HystrixCommandCompletionStreamTest.noEvents()
test_case.full_signature: @Test public void noEvents()
test_case.identifier: noEvents
test_case.invocations: getLatchedSubscriber subscribe take observe assertFalse await
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void noEvents()
focal_class.declarator: commandKey
focal_class.modifier: private final
focal_class.original_string: private final HystrixCommandKey commandKey;
focal_class.type: HystrixCommandKey
focal_class.var_name: commandKey
focal_class.declarator: writeOnlySubject
focal_class.modifier: private final
focal_class.original_string: private final Subject<HystrixCommandCompletion, HystrixCommandCompletion> writeOnlySubject;
focal_class.type: Subject<HystrixCommandCompletion, HystrixCommandCompletion>
focal_class.var_name: writeOnlySubject
focal_class.declarator: readOnlyStream
focal_class.modifier: private final
focal_class.original_string: private final Observable<HystrixCommandCompletion> readOnlyStream;
focal_class.type: Observable<HystrixCommandCompletion>
focal_class.var_name: readOnlyStream
focal_class.declarator: streams = new ConcurrentHashMap<String, HystrixCommandCompletionStream>()
focal_class.modifier: private static final
focal_class.original_string: private static final ConcurrentMap<String, HystrixCommandCompletionStream> streams = new ConcurrentHashMap<String, HystrixCommandCompletionStream>();
focal_class.type: ConcurrentMap<String, HystrixCommandCompletionStream>
focal_class.var_name: streams
focal_class.file: hystrix-core/src/main/java/com/netflix/hystrix/metric/HystrixCommandCompletionStream.java
focal_class.identifier: HystrixCommandCompletionStream
focal_class.interfaces: implements HystrixEventStream<HystrixCommandCompletion>
focal_class.class_method_signature: HystrixCommandCompletionStream.getInstance(HystrixCommandKey commandKey)
focal_class.full_signature: public static HystrixCommandCompletionStream getInstance(HystrixCommandKey commandKey)
focal_class.identifier: getInstance
focal_class.modifiers: public static
focal_class.parameters: (HystrixCommandKey commandKey)
focal_class.return: HystrixCommandCompletionStream
focal_class.signature: HystrixCommandCompletionStream getInstance(HystrixCommandKey commandKey)
focal_class.class_method_signature: HystrixCommandCompletionStream.HystrixCommandCompletionStream(final HystrixCommandKey commandKey)
focal_class.full_signature:   HystrixCommandCompletionStream(final HystrixCommandKey commandKey)
focal_class.identifier: HystrixCommandCompletionStream
focal_class.parameters: (final HystrixCommandKey commandKey)
focal_class.signature:  HystrixCommandCompletionStream(final HystrixCommandKey commandKey)
focal_class.class_method_signature: HystrixCommandCompletionStream.reset()
focal_class.full_signature: public static void reset()
focal_class.identifier: reset
focal_class.modifiers: public static
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void reset()
focal_class.class_method_signature: HystrixCommandCompletionStream.write(HystrixCommandCompletion event)
focal_class.full_signature: public void write(HystrixCommandCompletion event)
focal_class.identifier: write
focal_class.modifiers: public
focal_class.parameters: (HystrixCommandCompletion event)
focal_class.return: void
focal_class.signature: void write(HystrixCommandCompletion event)
focal_class.class_method_signature: HystrixCommandCompletionStream.observe()
focal_class.full_signature: @Override public Observable<HystrixCommandCompletion> observe()
focal_class.identifier: observe
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: Observable<HystrixCommandCompletion>
focal_class.signature: Observable<HystrixCommandCompletion> observe()
focal_class.class_method_signature: HystrixCommandCompletionStream.toString()
focal_class.full_signature: @Override public String toString()
focal_class.identifier: toString
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: String
focal_class.signature: String toString()
focal_method.body: @Override
      public Observable<HystrixCommandCompletion> observe() {
          return readOnlyStream;
      }
focal_method.class_method_signature: HystrixCommandCompletionStream.observe()
focal_method.full_signature: @Override public Observable<HystrixCommandCompletion> observe()
focal_method.identifier: observe
focal_method.modifiers: @Override public
focal_method.parameters: ()
focal_method.return: Observable<HystrixCommandCompletion>
focal_method.signature: Observable<HystrixCommandCompletion> observe()