test_class.file: rxjava/src/test/java/io/reactivex/parallel/ParallelFlowableTest.java
test_class.identifier: ParallelFlowableTest
test_case.body: @Test
      public void flatMapSubscriberCount() {
          ParallelFlowableTest.checkSubscriberCount(Flowable.range(1, 5).parallel()
          .flatMap(Functions.justFunction(Flowable.just(1))));
      }
test_case.class_method_signature: ParallelFlowableTest.flatMapSubscriberCount()
test_case.full_signature: @Test public void flatMapSubscriberCount()
test_case.identifier: flatMapSubscriberCount
test_case.invocations: checkSubscriberCount flatMap parallel range justFunction just
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void flatMapSubscriberCount()
focal_class.file: rxjava/src/main/java/io/reactivex/parallel/ParallelFlowable.java
focal_class.identifier: ParallelFlowable
focal_class.class_method_signature: ParallelFlowable.subscribe(@NonNull Subscriber<? super T>[] subscribers)
focal_class.full_signature: public abstract void subscribe(@NonNull Subscriber<? super T>[] subscribers)
focal_class.identifier: subscribe
focal_class.modifiers: public abstract
focal_class.parameters: (@NonNull Subscriber<? super T>[] subscribers)
focal_class.return: void
focal_class.signature: void subscribe(@NonNull Subscriber<? super T>[] subscribers)
focal_class.class_method_signature: ParallelFlowable.parallelism()
focal_class.full_signature: public abstract int parallelism()
focal_class.identifier: parallelism
focal_class.modifiers: public abstract
focal_class.parameters: ()
focal_class.return: int
focal_class.signature: int parallelism()
focal_class.class_method_signature: ParallelFlowable.validate(@NonNull Subscriber<?>[] subscribers)
focal_class.full_signature: protected final boolean validate(@NonNull Subscriber<?>[] subscribers)
focal_class.identifier: validate
focal_class.modifiers: protected final
focal_class.parameters: (@NonNull Subscriber<?>[] subscribers)
focal_class.return: boolean
focal_class.signature: boolean validate(@NonNull Subscriber<?>[] subscribers)
focal_class.class_method_signature: ParallelFlowable.from(@NonNull Publisher<? extends T> source)
focal_class.full_signature: @CheckReturnValue public static ParallelFlowable<T> from(@NonNull Publisher<? extends T> source)
focal_class.identifier: from
focal_class.modifiers: @CheckReturnValue public static
focal_class.parameters: (@NonNull Publisher<? extends T> source)
focal_class.return: ParallelFlowable<T>
focal_class.signature: ParallelFlowable<T> from(@NonNull Publisher<? extends T> source)
focal_class.class_method_signature: ParallelFlowable.from(@NonNull Publisher<? extends T> source, int parallelism)
focal_class.full_signature: @CheckReturnValue public static ParallelFlowable<T> from(@NonNull Publisher<? extends T> source, int parallelism)
focal_class.identifier: from
focal_class.modifiers: @CheckReturnValue public static
focal_class.parameters: (@NonNull Publisher<? extends T> source, int parallelism)
focal_class.return: ParallelFlowable<T>
focal_class.signature: ParallelFlowable<T> from(@NonNull Publisher<? extends T> source, int parallelism)
focal_class.class_method_signature: ParallelFlowable.from(@NonNull Publisher<? extends T> source,
              int parallelism, int prefetch)
focal_class.full_signature: @CheckReturnValue @NonNull public static ParallelFlowable<T> from(@NonNull Publisher<? extends T> source,
              int parallelism, int prefetch)
focal_class.identifier: from
focal_class.modifiers: @CheckReturnValue @NonNull public static
focal_class.parameters: (@NonNull Publisher<? extends T> source,
              int parallelism, int prefetch)
focal_class.return: ParallelFlowable<T>
focal_class.signature: ParallelFlowable<T> from(@NonNull Publisher<? extends T> source,
              int parallelism, int prefetch)
focal_class.class_method_signature: ParallelFlowable.as(@NonNull ParallelFlowableConverter<T, R> converter)
focal_class.full_signature: @Experimental @CheckReturnValue @NonNull public final R as(@NonNull ParallelFlowableConverter<T, R> converter)
focal_class.identifier: as
focal_class.modifiers: @Experimental @CheckReturnValue @NonNull public final
focal_class.parameters: (@NonNull ParallelFlowableConverter<T, R> converter)
focal_class.return: R
focal_class.signature: R as(@NonNull ParallelFlowableConverter<T, R> converter)
focal_class.class_method_signature: ParallelFlowable.map(@NonNull Function<? super T, ? extends R> mapper)
focal_class.full_signature: @CheckReturnValue @NonNull public final ParallelFlowable<R> map(@NonNull Function<? super T, ? extends R> mapper)
focal_class.identifier: map
focal_class.modifiers: @CheckReturnValue @NonNull public final
focal_class.parameters: (@NonNull Function<? super T, ? extends R> mapper)
focal_class.return: ParallelFlowable<R>
focal_class.signature: ParallelFlowable<R> map(@NonNull Function<? super T, ? extends R> mapper)
focal_class.class_method_signature: ParallelFlowable.map(@NonNull Function<? super T, ? extends R> mapper, @NonNull ParallelFailureHandling errorHandler)
focal_class.full_signature: @CheckReturnValue @Experimental @NonNull public final ParallelFlowable<R> map(@NonNull Function<? super T, ? extends R> mapper, @NonNull ParallelFailureHandling errorHandler)
focal_class.identifier: map
focal_class.modifiers: @CheckReturnValue @Experimental @NonNull public final
focal_class.parameters: (@NonNull Function<? super T, ? extends R> mapper, @NonNull ParallelFailureHandling errorHandler)
focal_class.return: ParallelFlowable<R>
focal_class.signature: ParallelFlowable<R> map(@NonNull Function<? super T, ? extends R> mapper, @NonNull ParallelFailureHandling errorHandler)
focal_class.class_method_signature: ParallelFlowable.map(@NonNull Function<? super T, ? extends R> mapper, @NonNull BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler)
focal_class.full_signature: @CheckReturnValue @Experimental @NonNull public final ParallelFlowable<R> map(@NonNull Function<? super T, ? extends R> mapper, @NonNull BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler)
focal_class.identifier: map
focal_class.modifiers: @CheckReturnValue @Experimental @NonNull public final
focal_class.parameters: (@NonNull Function<? super T, ? extends R> mapper, @NonNull BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler)
focal_class.return: ParallelFlowable<R>
focal_class.signature: ParallelFlowable<R> map(@NonNull Function<? super T, ? extends R> mapper, @NonNull BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler)
focal_class.class_method_signature: ParallelFlowable.filter(@NonNull Predicate<? super T> predicate)
focal_class.full_signature: @CheckReturnValue public final ParallelFlowable<T> filter(@NonNull Predicate<? super T> predicate)
focal_class.identifier: filter
focal_class.modifiers: @CheckReturnValue public final
focal_class.parameters: (@NonNull Predicate<? super T> predicate)
focal_class.return: ParallelFlowable<T>
focal_class.signature: ParallelFlowable<T> filter(@NonNull Predicate<? super T> predicate)
focal_class.class_method_signature: ParallelFlowable.filter(@NonNull Predicate<? super T> predicate, @NonNull ParallelFailureHandling errorHandler)
focal_class.full_signature: @CheckReturnValue @Experimental public final ParallelFlowable<T> filter(@NonNull Predicate<? super T> predicate, @NonNull ParallelFailureHandling errorHandler)
focal_class.identifier: filter
focal_class.modifiers: @CheckReturnValue @Experimental public final
focal_class.parameters: (@NonNull Predicate<? super T> predicate, @NonNull ParallelFailureHandling errorHandler)
focal_class.return: ParallelFlowable<T>
focal_class.signature: ParallelFlowable<T> filter(@NonNull Predicate<? super T> predicate, @NonNull ParallelFailureHandling errorHandler)
focal_class.class_method_signature: ParallelFlowable.filter(@NonNull Predicate<? super T> predicate, @NonNull BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler)
focal_class.full_signature: @CheckReturnValue @Experimental public final ParallelFlowable<T> filter(@NonNull Predicate<? super T> predicate, @NonNull BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler)
focal_class.identifier: filter
focal_class.modifiers: @CheckReturnValue @Experimental public final
focal_class.parameters: (@NonNull Predicate<? super T> predicate, @NonNull BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler)
focal_class.return: ParallelFlowable<T>
focal_class.signature: ParallelFlowable<T> filter(@NonNull Predicate<? super T> predicate, @NonNull BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler)
focal_class.class_method_signature: ParallelFlowable.runOn(@NonNull Scheduler scheduler)
focal_class.full_signature: @CheckReturnValue @NonNull public final ParallelFlowable<T> runOn(@NonNull Scheduler scheduler)
focal_class.identifier: runOn
focal_class.modifiers: @CheckReturnValue @NonNull public final
focal_class.parameters: (@NonNull Scheduler scheduler)
focal_class.return: ParallelFlowable<T>
focal_class.signature: ParallelFlowable<T> runOn(@NonNull Scheduler scheduler)
focal_class.class_method_signature: ParallelFlowable.runOn(@NonNull Scheduler scheduler, int prefetch)
focal_class.full_signature: @CheckReturnValue @NonNull public final ParallelFlowable<T> runOn(@NonNull Scheduler scheduler, int prefetch)
focal_class.identifier: runOn
focal_class.modifiers: @CheckReturnValue @NonNull public final
focal_class.parameters: (@NonNull Scheduler scheduler, int prefetch)
focal_class.return: ParallelFlowable<T>
focal_class.signature: ParallelFlowable<T> runOn(@NonNull Scheduler scheduler, int prefetch)
focal_class.class_method_signature: ParallelFlowable.reduce(@NonNull BiFunction<T, T, T> reducer)
focal_class.full_signature: @CheckReturnValue @NonNull public final Flowable<T> reduce(@NonNull BiFunction<T, T, T> reducer)
focal_class.identifier: reduce
focal_class.modifiers: @CheckReturnValue @NonNull public final
focal_class.parameters: (@NonNull BiFunction<T, T, T> reducer)
focal_class.return: Flowable<T>
focal_class.signature: Flowable<T> reduce(@NonNull BiFunction<T, T, T> reducer)
focal_class.class_method_signature: ParallelFlowable.reduce(@NonNull Callable<R> initialSupplier, @NonNull BiFunction<R, ? super T, R> reducer)
focal_class.full_signature: @CheckReturnValue @NonNull public final ParallelFlowable<R> reduce(@NonNull Callable<R> initialSupplier, @NonNull BiFunction<R, ? super T, R> reducer)
focal_class.identifier: reduce
focal_class.modifiers: @CheckReturnValue @NonNull public final
focal_class.parameters: (@NonNull Callable<R> initialSupplier, @NonNull BiFunction<R, ? super T, R> reducer)
focal_class.return: ParallelFlowable<R>
focal_class.signature: ParallelFlowable<R> reduce(@NonNull Callable<R> initialSupplier, @NonNull BiFunction<R, ? super T, R> reducer)
focal_class.class_method_signature: ParallelFlowable.sequential()
focal_class.full_signature: @BackpressureSupport(BackpressureKind.FULL) @SchedulerSupport(SchedulerSupport.NONE) @CheckReturnValue public final Flowable<T> sequential()
focal_class.identifier: sequential
focal_class.modifiers: @BackpressureSupport(BackpressureKind.FULL) @SchedulerSupport(SchedulerSupport.NONE) @CheckReturnValue public final
focal_class.parameters: ()
focal_class.return: Flowable<T>
focal_class.signature: Flowable<T> sequential()
focal_class.class_method_signature: ParallelFlowable.sequential(int prefetch)
focal_class.full_signature: @BackpressureSupport(BackpressureKind.FULL) @SchedulerSupport(SchedulerSupport.NONE) @CheckReturnValue @NonNull public final Flowable<T> sequential(int prefetch)
focal_class.identifier: sequential
focal_class.modifiers: @BackpressureSupport(BackpressureKind.FULL) @SchedulerSupport(SchedulerSupport.NONE) @CheckReturnValue @NonNull public final
focal_class.parameters: (int prefetch)
focal_class.return: Flowable<T>
focal_class.signature: Flowable<T> sequential(int prefetch)
focal_class.class_method_signature: ParallelFlowable.sequentialDelayError()
focal_class.full_signature: @BackpressureSupport(BackpressureKind.FULL) @SchedulerSupport(SchedulerSupport.NONE) @CheckReturnValue @Experimental @NonNull public final Flowable<T> sequentialDelayError()
focal_class.identifier: sequentialDelayError
focal_class.modifiers: @BackpressureSupport(BackpressureKind.FULL) @SchedulerSupport(SchedulerSupport.NONE) @CheckReturnValue @Experimental @NonNull public final
focal_class.parameters: ()
focal_class.return: Flowable<T>
focal_class.signature: Flowable<T> sequentialDelayError()
focal_class.class_method_signature: ParallelFlowable.sequentialDelayError(int prefetch)
focal_class.full_signature: @BackpressureSupport(BackpressureKind.FULL) @SchedulerSupport(SchedulerSupport.NONE) @CheckReturnValue @NonNull public final Flowable<T> sequentialDelayError(int prefetch)
focal_class.identifier: sequentialDelayError
focal_class.modifiers: @BackpressureSupport(BackpressureKind.FULL) @SchedulerSupport(SchedulerSupport.NONE) @CheckReturnValue @NonNull public final
focal_class.parameters: (int prefetch)
focal_class.return: Flowable<T>
focal_class.signature: Flowable<T> sequentialDelayError(int prefetch)
focal_class.class_method_signature: ParallelFlowable.sorted(@NonNull Comparator<? super T> comparator)
focal_class.full_signature: @CheckReturnValue @NonNull public final Flowable<T> sorted(@NonNull Comparator<? super T> comparator)
focal_class.identifier: sorted
focal_class.modifiers: @CheckReturnValue @NonNull public final
focal_class.parameters: (@NonNull Comparator<? super T> comparator)
focal_class.return: Flowable<T>
focal_class.signature: Flowable<T> sorted(@NonNull Comparator<? super T> comparator)
focal_class.class_method_signature: ParallelFlowable.sorted(@NonNull Comparator<? super T> comparator, int capacityHint)
focal_class.full_signature: @CheckReturnValue @NonNull public final Flowable<T> sorted(@NonNull Comparator<? super T> comparator, int capacityHint)
focal_class.identifier: sorted
focal_class.modifiers: @CheckReturnValue @NonNull public final
focal_class.parameters: (@NonNull Comparator<? super T> comparator, int capacityHint)
focal_class.return: Flowable<T>
focal_class.signature: Flowable<T> sorted(@NonNull Comparator<? super T> comparator, int capacityHint)
focal_class.class_method_signature: ParallelFlowable.toSortedList(@NonNull Comparator<? super T> comparator)
focal_class.full_signature: @CheckReturnValue @NonNull public final Flowable<List<T>> toSortedList(@NonNull Comparator<? super T> comparator)
focal_class.identifier: toSortedList
focal_class.modifiers: @CheckReturnValue @NonNull public final
focal_class.parameters: (@NonNull Comparator<? super T> comparator)
focal_class.return: Flowable<List<T>>
focal_class.signature: Flowable<List<T>> toSortedList(@NonNull Comparator<? super T> comparator)
focal_class.class_method_signature: ParallelFlowable.toSortedList(@NonNull Comparator<? super T> comparator, int capacityHint)
focal_class.full_signature: @CheckReturnValue @NonNull public final Flowable<List<T>> toSortedList(@NonNull Comparator<? super T> comparator, int capacityHint)
focal_class.identifier: toSortedList
focal_class.modifiers: @CheckReturnValue @NonNull public final
focal_class.parameters: (@NonNull Comparator<? super T> comparator, int capacityHint)
focal_class.return: Flowable<List<T>>
focal_class.signature: Flowable<List<T>> toSortedList(@NonNull Comparator<? super T> comparator, int capacityHint)
focal_class.class_method_signature: ParallelFlowable.doOnNext(@NonNull Consumer<? super T> onNext)
focal_class.full_signature: @CheckReturnValue @NonNull public final ParallelFlowable<T> doOnNext(@NonNull Consumer<? super T> onNext)
focal_class.identifier: doOnNext
focal_class.modifiers: @CheckReturnValue @NonNull public final
focal_class.parameters: (@NonNull Consumer<? super T> onNext)
focal_class.return: ParallelFlowable<T>
focal_class.signature: ParallelFlowable<T> doOnNext(@NonNull Consumer<? super T> onNext)
focal_class.class_method_signature: ParallelFlowable.doOnNext(@NonNull Consumer<? super T> onNext, @NonNull ParallelFailureHandling errorHandler)
focal_class.full_signature: @CheckReturnValue @Experimental @NonNull public final ParallelFlowable<T> doOnNext(@NonNull Consumer<? super T> onNext, @NonNull ParallelFailureHandling errorHandler)
focal_class.identifier: doOnNext
focal_class.modifiers: @CheckReturnValue @Experimental @NonNull public final
focal_class.parameters: (@NonNull Consumer<? super T> onNext, @NonNull ParallelFailureHandling errorHandler)
focal_class.return: ParallelFlowable<T>
focal_class.signature: ParallelFlowable<T> doOnNext(@NonNull Consumer<? super T> onNext, @NonNull ParallelFailureHandling errorHandler)
focal_class.class_method_signature: ParallelFlowable.doOnNext(@NonNull Consumer<? super T> onNext, @NonNull BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler)
focal_class.full_signature: @CheckReturnValue @Experimental @NonNull public final ParallelFlowable<T> doOnNext(@NonNull Consumer<? super T> onNext, @NonNull BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler)
focal_class.identifier: doOnNext
focal_class.modifiers: @CheckReturnValue @Experimental @NonNull public final
focal_class.parameters: (@NonNull Consumer<? super T> onNext, @NonNull BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler)
focal_class.return: ParallelFlowable<T>
focal_class.signature: ParallelFlowable<T> doOnNext(@NonNull Consumer<? super T> onNext, @NonNull BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler)
focal_class.class_method_signature: ParallelFlowable.doAfterNext(@NonNull Consumer<? super T> onAfterNext)
focal_class.full_signature: @CheckReturnValue @NonNull public final ParallelFlowable<T> doAfterNext(@NonNull Consumer<? super T> onAfterNext)
focal_class.identifier: doAfterNext
focal_class.modifiers: @CheckReturnValue @NonNull public final
focal_class.parameters: (@NonNull Consumer<? super T> onAfterNext)
focal_class.return: ParallelFlowable<T>
focal_class.signature: ParallelFlowable<T> doAfterNext(@NonNull Consumer<? super T> onAfterNext)
focal_class.class_method_signature: ParallelFlowable.doOnError(@NonNull Consumer<Throwable> onError)
focal_class.full_signature: @CheckReturnValue @NonNull public final ParallelFlowable<T> doOnError(@NonNull Consumer<Throwable> onError)
focal_class.identifier: doOnError
focal_class.modifiers: @CheckReturnValue @NonNull public final
focal_class.parameters: (@NonNull Consumer<Throwable> onError)
focal_class.return: ParallelFlowable<T>
focal_class.signature: ParallelFlowable<T> doOnError(@NonNull Consumer<Throwable> onError)
focal_class.class_method_signature: ParallelFlowable.doOnComplete(@NonNull Action onComplete)
focal_class.full_signature: @CheckReturnValue @NonNull public final ParallelFlowable<T> doOnComplete(@NonNull Action onComplete)
focal_class.identifier: doOnComplete
focal_class.modifiers: @CheckReturnValue @NonNull public final
focal_class.parameters: (@NonNull Action onComplete)
focal_class.return: ParallelFlowable<T>
focal_class.signature: ParallelFlowable<T> doOnComplete(@NonNull Action onComplete)
focal_class.class_method_signature: ParallelFlowable.doAfterTerminated(@NonNull Action onAfterTerminate)
focal_class.full_signature: @CheckReturnValue @NonNull public final ParallelFlowable<T> doAfterTerminated(@NonNull Action onAfterTerminate)
focal_class.identifier: doAfterTerminated
focal_class.modifiers: @CheckReturnValue @NonNull public final
focal_class.parameters: (@NonNull Action onAfterTerminate)
focal_class.return: ParallelFlowable<T>
focal_class.signature: ParallelFlowable<T> doAfterTerminated(@NonNull Action onAfterTerminate)
focal_class.class_method_signature: ParallelFlowable.doOnSubscribe(@NonNull Consumer<? super Subscription> onSubscribe)
focal_class.full_signature: @CheckReturnValue @NonNull public final ParallelFlowable<T> doOnSubscribe(@NonNull Consumer<? super Subscription> onSubscribe)
focal_class.identifier: doOnSubscribe
focal_class.modifiers: @CheckReturnValue @NonNull public final
focal_class.parameters: (@NonNull Consumer<? super Subscription> onSubscribe)
focal_class.return: ParallelFlowable<T>
focal_class.signature: ParallelFlowable<T> doOnSubscribe(@NonNull Consumer<? super Subscription> onSubscribe)
focal_class.class_method_signature: ParallelFlowable.doOnRequest(@NonNull LongConsumer onRequest)
focal_class.full_signature: @CheckReturnValue @NonNull public final ParallelFlowable<T> doOnRequest(@NonNull LongConsumer onRequest)
focal_class.identifier: doOnRequest
focal_class.modifiers: @CheckReturnValue @NonNull public final
focal_class.parameters: (@NonNull LongConsumer onRequest)
focal_class.return: ParallelFlowable<T>
focal_class.signature: ParallelFlowable<T> doOnRequest(@NonNull LongConsumer onRequest)
focal_class.class_method_signature: ParallelFlowable.doOnCancel(@NonNull Action onCancel)
focal_class.full_signature: @CheckReturnValue @NonNull public final ParallelFlowable<T> doOnCancel(@NonNull Action onCancel)
focal_class.identifier: doOnCancel
focal_class.modifiers: @CheckReturnValue @NonNull public final
focal_class.parameters: (@NonNull Action onCancel)
focal_class.return: ParallelFlowable<T>
focal_class.signature: ParallelFlowable<T> doOnCancel(@NonNull Action onCancel)
focal_class.class_method_signature: ParallelFlowable.collect(@NonNull Callable<? extends C> collectionSupplier, @NonNull BiConsumer<? super C, ? super T> collector)
focal_class.full_signature: @CheckReturnValue @NonNull public final ParallelFlowable<C> collect(@NonNull Callable<? extends C> collectionSupplier, @NonNull BiConsumer<? super C, ? super T> collector)
focal_class.identifier: collect
focal_class.modifiers: @CheckReturnValue @NonNull public final
focal_class.parameters: (@NonNull Callable<? extends C> collectionSupplier, @NonNull BiConsumer<? super C, ? super T> collector)
focal_class.return: ParallelFlowable<C>
focal_class.signature: ParallelFlowable<C> collect(@NonNull Callable<? extends C> collectionSupplier, @NonNull BiConsumer<? super C, ? super T> collector)
focal_class.class_method_signature: ParallelFlowable.fromArray(@NonNull Publisher<T>... publishers)
focal_class.full_signature: @CheckReturnValue @NonNull public static ParallelFlowable<T> fromArray(@NonNull Publisher<T>... publishers)
focal_class.identifier: fromArray
focal_class.modifiers: @CheckReturnValue @NonNull public static
focal_class.parameters: (@NonNull Publisher<T>... publishers)
focal_class.return: ParallelFlowable<T>
focal_class.signature: ParallelFlowable<T> fromArray(@NonNull Publisher<T>... publishers)
focal_class.class_method_signature: ParallelFlowable.to(@NonNull Function<? super ParallelFlowable<T>, U> converter)
focal_class.full_signature: @CheckReturnValue @NonNull public final U to(@NonNull Function<? super ParallelFlowable<T>, U> converter)
focal_class.identifier: to
focal_class.modifiers: @CheckReturnValue @NonNull public final
focal_class.parameters: (@NonNull Function<? super ParallelFlowable<T>, U> converter)
focal_class.return: U
focal_class.signature: U to(@NonNull Function<? super ParallelFlowable<T>, U> converter)
focal_class.class_method_signature: ParallelFlowable.compose(@NonNull ParallelTransformer<T, U> composer)
focal_class.full_signature: @CheckReturnValue @NonNull public final ParallelFlowable<U> compose(@NonNull ParallelTransformer<T, U> composer)
focal_class.identifier: compose
focal_class.modifiers: @CheckReturnValue @NonNull public final
focal_class.parameters: (@NonNull ParallelTransformer<T, U> composer)
focal_class.return: ParallelFlowable<U>
focal_class.signature: ParallelFlowable<U> compose(@NonNull ParallelTransformer<T, U> composer)
focal_class.class_method_signature: ParallelFlowable.flatMap(@NonNull Function<? super T, ? extends Publisher<? extends R>> mapper)
focal_class.full_signature: @CheckReturnValue @NonNull public final ParallelFlowable<R> flatMap(@NonNull Function<? super T, ? extends Publisher<? extends R>> mapper)
focal_class.identifier: flatMap
focal_class.modifiers: @CheckReturnValue @NonNull public final
focal_class.parameters: (@NonNull Function<? super T, ? extends Publisher<? extends R>> mapper)
focal_class.return: ParallelFlowable<R>
focal_class.signature: ParallelFlowable<R> flatMap(@NonNull Function<? super T, ? extends Publisher<? extends R>> mapper)
focal_class.class_method_signature: ParallelFlowable.flatMap(
              @NonNull Function<? super T, ? extends Publisher<? extends R>> mapper, boolean delayError)
focal_class.full_signature: @CheckReturnValue @NonNull public final ParallelFlowable<R> flatMap(
              @NonNull Function<? super T, ? extends Publisher<? extends R>> mapper, boolean delayError)
focal_class.identifier: flatMap
focal_class.modifiers: @CheckReturnValue @NonNull public final
focal_class.parameters: (
              @NonNull Function<? super T, ? extends Publisher<? extends R>> mapper, boolean delayError)
focal_class.return: ParallelFlowable<R>
focal_class.signature: ParallelFlowable<R> flatMap(
              @NonNull Function<? super T, ? extends Publisher<? extends R>> mapper, boolean delayError)
focal_class.class_method_signature: ParallelFlowable.flatMap(
              @NonNull Function<? super T, ? extends Publisher<? extends R>> mapper, boolean delayError, int maxConcurrency)
focal_class.full_signature: @CheckReturnValue @NonNull public final ParallelFlowable<R> flatMap(
              @NonNull Function<? super T, ? extends Publisher<? extends R>> mapper, boolean delayError, int maxConcurrency)
focal_class.identifier: flatMap
focal_class.modifiers: @CheckReturnValue @NonNull public final
focal_class.parameters: (
              @NonNull Function<? super T, ? extends Publisher<? extends R>> mapper, boolean delayError, int maxConcurrency)
focal_class.return: ParallelFlowable<R>
focal_class.signature: ParallelFlowable<R> flatMap(
              @NonNull Function<? super T, ? extends Publisher<? extends R>> mapper, boolean delayError, int maxConcurrency)
focal_class.class_method_signature: ParallelFlowable.flatMap(
              @NonNull Function<? super T, ? extends Publisher<? extends R>> mapper,
              boolean delayError, int maxConcurrency, int prefetch)
focal_class.full_signature: @CheckReturnValue @NonNull public final ParallelFlowable<R> flatMap(
              @NonNull Function<? super T, ? extends Publisher<? extends R>> mapper,
              boolean delayError, int maxConcurrency, int prefetch)
focal_class.identifier: flatMap
focal_class.modifiers: @CheckReturnValue @NonNull public final
focal_class.parameters: (
              @NonNull Function<? super T, ? extends Publisher<? extends R>> mapper,
              boolean delayError, int maxConcurrency, int prefetch)
focal_class.return: ParallelFlowable<R>
focal_class.signature: ParallelFlowable<R> flatMap(
              @NonNull Function<? super T, ? extends Publisher<? extends R>> mapper,
              boolean delayError, int maxConcurrency, int prefetch)
focal_class.class_method_signature: ParallelFlowable.concatMap(
              @NonNull Function<? super T, ? extends Publisher<? extends R>> mapper)
focal_class.full_signature: @CheckReturnValue @NonNull public final ParallelFlowable<R> concatMap(
              @NonNull Function<? super T, ? extends Publisher<? extends R>> mapper)
focal_class.identifier: concatMap
focal_class.modifiers: @CheckReturnValue @NonNull public final
focal_class.parameters: (
              @NonNull Function<? super T, ? extends Publisher<? extends R>> mapper)
focal_class.return: ParallelFlowable<R>
focal_class.signature: ParallelFlowable<R> concatMap(
              @NonNull Function<? super T, ? extends Publisher<? extends R>> mapper)
focal_class.class_method_signature: ParallelFlowable.concatMap(
              @NonNull Function<? super T, ? extends Publisher<? extends R>> mapper,
                      int prefetch)
focal_class.full_signature: @CheckReturnValue @NonNull public final ParallelFlowable<R> concatMap(
              @NonNull Function<? super T, ? extends Publisher<? extends R>> mapper,
                      int prefetch)
focal_class.identifier: concatMap
focal_class.modifiers: @CheckReturnValue @NonNull public final
focal_class.parameters: (
              @NonNull Function<? super T, ? extends Publisher<? extends R>> mapper,
                      int prefetch)
focal_class.return: ParallelFlowable<R>
focal_class.signature: ParallelFlowable<R> concatMap(
              @NonNull Function<? super T, ? extends Publisher<? extends R>> mapper,
                      int prefetch)
focal_class.class_method_signature: ParallelFlowable.concatMapDelayError(
              @NonNull Function<? super T, ? extends Publisher<? extends R>> mapper,
                      boolean tillTheEnd)
focal_class.full_signature: @CheckReturnValue @NonNull public final ParallelFlowable<R> concatMapDelayError(
              @NonNull Function<? super T, ? extends Publisher<? extends R>> mapper,
                      boolean tillTheEnd)
focal_class.identifier: concatMapDelayError
focal_class.modifiers: @CheckReturnValue @NonNull public final
focal_class.parameters: (
              @NonNull Function<? super T, ? extends Publisher<? extends R>> mapper,
                      boolean tillTheEnd)
focal_class.return: ParallelFlowable<R>
focal_class.signature: ParallelFlowable<R> concatMapDelayError(
              @NonNull Function<? super T, ? extends Publisher<? extends R>> mapper,
                      boolean tillTheEnd)
focal_class.class_method_signature: ParallelFlowable.concatMapDelayError(
              @NonNull Function<? super T, ? extends Publisher<? extends R>> mapper,
                      int prefetch, boolean tillTheEnd)
focal_class.full_signature: @CheckReturnValue @NonNull public final ParallelFlowable<R> concatMapDelayError(
              @NonNull Function<? super T, ? extends Publisher<? extends R>> mapper,
                      int prefetch, boolean tillTheEnd)
focal_class.identifier: concatMapDelayError
focal_class.modifiers: @CheckReturnValue @NonNull public final
focal_class.parameters: (
              @NonNull Function<? super T, ? extends Publisher<? extends R>> mapper,
                      int prefetch, boolean tillTheEnd)
focal_class.return: ParallelFlowable<R>
focal_class.signature: ParallelFlowable<R> concatMapDelayError(
              @NonNull Function<? super T, ? extends Publisher<? extends R>> mapper,
                      int prefetch, boolean tillTheEnd)
focal_method.body: @CheckReturnValue
      @NonNull
      public final <R> ParallelFlowable<R> flatMap(@NonNull Function<? super T, ? extends Publisher<? extends R>> mapper) {
          return flatMap(mapper, false, Integer.MAX_VALUE, Flowable.bufferSize());
      }
focal_method.class_method_signature: ParallelFlowable.flatMap(@NonNull Function<? super T, ? extends Publisher<? extends R>> mapper)
focal_method.full_signature: @CheckReturnValue @NonNull public final ParallelFlowable<R> flatMap(@NonNull Function<? super T, ? extends Publisher<? extends R>> mapper)
focal_method.identifier: flatMap
focal_method.invocations: flatMap bufferSize
focal_method.modifiers: @CheckReturnValue @NonNull public final
focal_method.parameters: (@NonNull Function<? super T, ? extends Publisher<? extends R>> mapper)
focal_method.return: ParallelFlowable<R>
focal_method.signature: ParallelFlowable<R> flatMap(@NonNull Function<? super T, ? extends Publisher<? extends R>> mapper)