test_class.file: rxjava/src/test/java/io/reactivex/internal/operators/flowable/FlowableFlatMapTest.java
test_class.identifier: FlowableFlatMapTest
test_case.body: @Test
      public void rangeEmptyMixture() {
          TestSubscriber<Integer> ts = TestSubscriber.create();
  
          Flowable.range(0, 4 * Flowable.bufferSize())
          .flatMap(new Function<Integer, Flowable<Integer>>() {
              @Override
              public Flowable<Integer> apply(Integer v) {
                  return (v & 1) == 0 ? Flowable.<Integer>empty() : Flowable.range(v, 2);
              }
          })
          .subscribe(ts);
  
          ts.assertValueCount(4 * Flowable.bufferSize());
          ts.assertNoErrors();
          ts.assertComplete();
  
          int j = 1;
          List<Integer> list = ts.values();
          for (int i = 0; i < list.size(); i += 2) {
              Assert.assertEquals(j, list.get(i).intValue());
              Assert.assertEquals(j + 1, list.get(i + 1).intValue());
  
              j += 2;
          }
      }
test_case.class_method_signature: FlowableFlatMapTest.rangeEmptyMixture()
test_case.full_signature: @Test public void rangeEmptyMixture()
test_case.identifier: rangeEmptyMixture
test_case.invocations: create subscribe flatMap range bufferSize empty range assertValueCount bufferSize assertNoErrors assertComplete values size assertEquals intValue get assertEquals intValue get
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void rangeEmptyMixture()
focal_class.declarator: mapper
focal_class.modifier: final
focal_class.original_string: final Function<? super T, ? extends Publisher<? extends U>> mapper;
focal_class.type: Function<? super T, ? extends Publisher<? extends U>>
focal_class.var_name: mapper
focal_class.declarator: delayErrors
focal_class.modifier: final
focal_class.original_string: final boolean delayErrors;
focal_class.type: boolean
focal_class.var_name: delayErrors
focal_class.declarator: maxConcurrency
focal_class.modifier: final
focal_class.original_string: final int maxConcurrency;
focal_class.type: int
focal_class.var_name: maxConcurrency
focal_class.declarator: bufferSize
focal_class.modifier: final
focal_class.original_string: final int bufferSize;
focal_class.type: int
focal_class.var_name: bufferSize
focal_class.file: rxjava/src/main/java/io/reactivex/internal/operators/flowable/FlowableFlatMap.java
focal_class.identifier: FlowableFlatMap
focal_class.class_method_signature: FlowableFlatMap.FlowableFlatMap(Flowable<T> source,
              Function<? super T, ? extends Publisher<? extends U>> mapper,
              boolean delayErrors, int maxConcurrency, int bufferSize)
focal_class.full_signature: public  FlowableFlatMap(Flowable<T> source,
              Function<? super T, ? extends Publisher<? extends U>> mapper,
              boolean delayErrors, int maxConcurrency, int bufferSize)
focal_class.identifier: FlowableFlatMap
focal_class.modifiers: public
focal_class.parameters: (Flowable<T> source,
              Function<? super T, ? extends Publisher<? extends U>> mapper,
              boolean delayErrors, int maxConcurrency, int bufferSize)
focal_class.signature:  FlowableFlatMap(Flowable<T> source,
              Function<? super T, ? extends Publisher<? extends U>> mapper,
              boolean delayErrors, int maxConcurrency, int bufferSize)
focal_class.class_method_signature: FlowableFlatMap.subscribeActual(Subscriber<? super U> s)
focal_class.full_signature: @Override protected void subscribeActual(Subscriber<? super U> s)
focal_class.identifier: subscribeActual
focal_class.modifiers: @Override protected
focal_class.parameters: (Subscriber<? super U> s)
focal_class.return: void
focal_class.signature: void subscribeActual(Subscriber<? super U> s)
focal_class.class_method_signature: FlowableFlatMap.subscribe(Subscriber<? super U> s,
              Function<? super T, ? extends Publisher<? extends U>> mapper,
              boolean delayErrors, int maxConcurrency, int bufferSize)
focal_class.full_signature: public static FlowableSubscriber<T> subscribe(Subscriber<? super U> s,
              Function<? super T, ? extends Publisher<? extends U>> mapper,
              boolean delayErrors, int maxConcurrency, int bufferSize)
focal_class.identifier: subscribe
focal_class.modifiers: public static
focal_class.parameters: (Subscriber<? super U> s,
              Function<? super T, ? extends Publisher<? extends U>> mapper,
              boolean delayErrors, int maxConcurrency, int bufferSize)
focal_class.return: FlowableSubscriber<T>
focal_class.signature: FlowableSubscriber<T> subscribe(Subscriber<? super U> s,
              Function<? super T, ? extends Publisher<? extends U>> mapper,
              boolean delayErrors, int maxConcurrency, int bufferSize)
focal_class.superclass: extends AbstractFlowableWithUpstream<T, U>
focal_method.body: public static <T, U> FlowableSubscriber<T> subscribe(Subscriber<? super U> s,
              Function<? super T, ? extends Publisher<? extends U>> mapper,
              boolean delayErrors, int maxConcurrency, int bufferSize) {
          return new MergeSubscriber<T, U>(s, mapper, delayErrors, maxConcurrency, bufferSize);
      }
focal_method.class_method_signature: FlowableFlatMap.subscribe(Subscriber<? super U> s,
              Function<? super T, ? extends Publisher<? extends U>> mapper,
              boolean delayErrors, int maxConcurrency, int bufferSize)
focal_method.full_signature: public static FlowableSubscriber<T> subscribe(Subscriber<? super U> s,
              Function<? super T, ? extends Publisher<? extends U>> mapper,
              boolean delayErrors, int maxConcurrency, int bufferSize)
focal_method.identifier: subscribe
focal_method.modifiers: public static
focal_method.parameters: (Subscriber<? super U> s,
              Function<? super T, ? extends Publisher<? extends U>> mapper,
              boolean delayErrors, int maxConcurrency, int bufferSize)
focal_method.return: FlowableSubscriber<T>
focal_method.signature: FlowableSubscriber<T> subscribe(Subscriber<? super U> s,
              Function<? super T, ? extends Publisher<? extends U>> mapper,
              boolean delayErrors, int maxConcurrency, int bufferSize)