test_class.declarator: monitor
test_class.original_string: SamplingCollector monitor;
test_class.type: SamplingCollector
test_class.var_name: monitor
test_class.declarator: recieved
test_class.original_string: int recieved;
test_class.type: int
test_class.var_name: recieved
test_class.file: cyclops-futurestream/src/test/java/com/oath/cyclops/react/collectors/lazy/SamplingCollectorTest.java
test_class.identifier: SamplingCollectorTest
test_case.body: @Test
  	public void testSamplingMonitorIntIntConsumerOfCompletableFuture() {
  		monitor = new SamplingCollector(5,0,new MyConsumer(it->recieved++));
  		for(int i=0;i<100;i++)
  			monitor.accept(FastFuture.completedFuture(10));
  		assertThat(recieved, is(20));
  	}
test_case.class_method_signature: SamplingCollectorTest.testSamplingMonitorIntIntConsumerOfCompletableFuture()
test_case.full_signature: @Test public void testSamplingMonitorIntIntConsumerOfCompletableFuture()
test_case.identifier: testSamplingMonitorIntIntConsumerOfCompletableFuture
test_case.invocations: accept completedFuture assertThat is
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testSamplingMonitorIntIntConsumerOfCompletableFuture()
focal_class.declarator: sampleRate
focal_class.modifier: private final
focal_class.original_string: private final int sampleRate;
focal_class.type: int
focal_class.var_name: sampleRate
focal_class.declarator: count = 0
focal_class.modifier: private
focal_class.original_string: private long count = 0;
focal_class.type: long
focal_class.var_name: count
focal_class.declarator: consumer
focal_class.modifier: private final
focal_class.original_string: private final LazyResultConsumer<T> consumer;
focal_class.type: LazyResultConsumer<T>
focal_class.var_name: consumer
focal_class.file: cyclops-futurestream/src/main/java/com/oath/cyclops/react/collectors/lazy/SamplingCollector.java
focal_class.identifier: SamplingCollector
focal_class.interfaces: implements LazyResultConsumer<T>
focal_class.class_method_signature: SamplingCollector.SamplingCollector(final int sampleRate, final LazyResultConsumer<T> consumer)
focal_class.full_signature: public  SamplingCollector(final int sampleRate, final LazyResultConsumer<T> consumer)
focal_class.identifier: SamplingCollector
focal_class.modifiers: public
focal_class.parameters: (final int sampleRate, final LazyResultConsumer<T> consumer)
focal_class.signature:  SamplingCollector(final int sampleRate, final LazyResultConsumer<T> consumer)
focal_class.class_method_signature: SamplingCollector.accept(final FastFuture<T> t)
focal_class.full_signature: @Override public void accept(final FastFuture<T> t)
focal_class.identifier: accept
focal_class.modifiers: @Override public
focal_class.parameters: (final FastFuture<T> t)
focal_class.return: void
focal_class.signature: void accept(final FastFuture<T> t)
focal_class.class_method_signature: SamplingCollector.block(final Function<FastFuture<T>, T> safeJoin)
focal_class.full_signature: @Override public void block(final Function<FastFuture<T>, T> safeJoin)
focal_class.identifier: block
focal_class.modifiers: @Override public
focal_class.parameters: (final Function<FastFuture<T>, T> safeJoin)
focal_class.return: void
focal_class.signature: void block(final Function<FastFuture<T>, T> safeJoin)
focal_class.class_method_signature: SamplingCollector.withResults(final Collection<FastFuture<T>> t)
focal_class.full_signature: @Override public LazyResultConsumer<T> withResults(final Collection<FastFuture<T>> t)
focal_class.identifier: withResults
focal_class.modifiers: @Override public
focal_class.parameters: (final Collection<FastFuture<T>> t)
focal_class.return: LazyResultConsumer<T>
focal_class.signature: LazyResultConsumer<T> withResults(final Collection<FastFuture<T>> t)
focal_class.class_method_signature: SamplingCollector.getResults()
focal_class.full_signature: @Override public Collection<FastFuture<T>> getResults()
focal_class.identifier: getResults
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: Collection<FastFuture<T>>
focal_class.signature: Collection<FastFuture<T>> getResults()
focal_class.class_method_signature: SamplingCollector.getAllResults()
focal_class.full_signature: @Override public Collection<FastFuture<T>> getAllResults()
focal_class.identifier: getAllResults
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: Collection<FastFuture<T>>
focal_class.signature: Collection<FastFuture<T>> getAllResults()
focal_method.body: @Override
    public void accept(final FastFuture<T> t) {
      if (count++ % sampleRate == 0)
        consumer.accept(t);
  
    }
focal_method.class_method_signature: SamplingCollector.accept(final FastFuture<T> t)
focal_method.full_signature: @Override public void accept(final FastFuture<T> t)
focal_method.identifier: accept
focal_method.invocations: accept
focal_method.modifiers: @Override public
focal_method.parameters: (final FastFuture<T> t)
focal_method.return: void
focal_method.signature: void accept(final FastFuture<T> t)