ReactiveProducerAdapter create()

in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/ReactiveProducerAdapterFactory.java [37:43]

• 7 lines of code
• 2 McCabe index (conditional complexity)

	<T> ReactiveProducerAdapter<T> create(Function<PulsarClient, ProducerBuilder<T>> producerBuilderFactory,
			ProducerCache producerCache, Supplier<PublisherTransformer> producerActionTransformer,
			Object producerActionTransformerKey) {
		return new ReactiveProducerAdapter<>(this.pulsarClientSupplier, producerBuilderFactory, producerCache,
				(producerActionTransformer != null) ? producerActionTransformer : PublisherTransformer::identity,
				producerActionTransformerKey);
	}