DEFAULT_CONCURRENCY

Default concurrency limit that is used by flattenMerge and flatMapMerge operators. It is 16 by default and can be changed on JVM using DEFAULT_CONCURRENCY_PROPERTY_NAME property. This is a preview API and can be changed in a backwards-incompatible manner within a single release.