test_class.file: rxjava/src/test/java/io/reactivex/internal/operators/flowable/FlowableFlatMapTest.java
test_class.identifier: FlowableFlatMapTest
test_case.body: @Test
      public void flatMapIntPassthruAsync() {
          for (int i = 0;i < 1000; i++) {
              TestSubscriber<Integer> ts = new TestSubscriber<Integer>();
  
              Flowable.range(1, 1000).flatMap(new Function<Integer, Flowable<Integer>>() {
                  @Override
                  public Flowable<Integer> apply(Integer t) {
                      return Flowable.just(1).subscribeOn(Schedulers.computation());
                  }
              }).subscribe(ts);
  
              ts.awaitTerminalEvent(5, TimeUnit.SECONDS);
              ts.assertNoErrors();
              ts.assertComplete();
              ts.assertValueCount(1000);
          }
      }
test_case.class_method_signature: FlowableFlatMapTest.flatMapIntPassthruAsync()
test_case.full_signature: @Test public void flatMapIntPassthruAsync()
test_case.identifier: flatMapIntPassthruAsync
test_case.invocations: subscribe flatMap range subscribeOn just computation awaitTerminalEvent assertNoErrors assertComplete assertValueCount
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void flatMapIntPassthruAsync()
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)