private static Stream shouldSendMessageToTopicWithCachedProducer()

in pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/ReactiveMessageSenderE2ETests.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();
	}