test_class.file: rxjava/src/test/java/io/reactivex/internal/operators/flowable/FlowableFlatMapTest.java
test_class.identifier: FlowableFlatMapTest
test_case.body: @Ignore("Don't care for any reordering")
      @Test(timeout = 10000)
      public void flatMapRangeAsyncLoop() {
          for (int i = 0; i < 2000; i++) {
              if (i % 10 == 0) {
                  System.out.println("flatMapRangeAsyncLoop > " + i);
              }
              TestSubscriber<Integer> ts = new TestSubscriber<Integer>();
              Flowable.range(0, 1000)
              .flatMap(new Function<Integer, Flowable<Integer>>() {
                  @Override
                  public Flowable<Integer> apply(Integer t) {
                      return Flowable.just(t);
                  }
              })
              .observeOn(Schedulers.computation())
              .subscribe(ts);
  
              ts.awaitTerminalEvent(2500, TimeUnit.MILLISECONDS);
              if (ts.completions() == 0) {
                  System.out.println(ts.valueCount());
              }
              ts.assertTerminated();
              ts.assertNoErrors();
              List<Integer> list = ts.values();
              assertEquals(1000, list.size());
              boolean f = false;
              for (int j = 0; j < list.size(); j++) {
                  if (list.get(j) != j) {
                      System.out.println(j + " " + list.get(j));
                      f = true;
                  }
              }
              if (f) {
                  Assert.fail("Results are out of order!");
              }
          }
      }
test_case.class_method_signature: FlowableFlatMapTest.flatMapRangeAsyncLoop()
test_case.full_signature: @Ignore("Don't care for any reordering") @Test(timeout = 10000) public void flatMapRangeAsyncLoop()
test_case.identifier: flatMapRangeAsyncLoop
test_case.invocations: println subscribe observeOn flatMap range just computation awaitTerminalEvent completions println valueCount assertTerminated assertNoErrors values assertEquals size size get println get fail
test_case.modifiers: @Ignore("Don't care for any reordering") @Test(timeout = 10000) public
test_case.parameters: ()
test_case.return: void
test_case.signature: void flatMapRangeAsyncLoop()
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)