private static Stream shouldSendMessageToTopicWithCachedProducer()

in pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/ReactiveMessageSenderE2ETest.java [49:59]

• 11 lines of code
• 1 McCabe index (conditional complexity)

	private static Stream<Arguments> shouldSendMessageToTopicWithCachedProducer() {
		return Arrays.asList(
				Arguments.of("ConcurrentHashMapProducerCacheProvider",
						AdaptedReactivePulsarClientFactory.createCache(new ConcurrentHashMapProducerCacheProvider())),
				Arguments.of("Default", AdaptedReactivePulsarClientFactory.createCache()),
				Arguments.of("CaffeineProducerCacheProvider",
						AdaptedReactivePulsarClientFactory.createCache(new CaffeineProducerCacheProvider())),
				Arguments.of("CaffeineShadedProducerCacheProvider",
						AdaptedReactivePulsarClientFactory.createCache(new CaffeineShadedProducerCacheProvider())))
				.stream();
	}