in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/AdaptedReactiveMessageSenderBuilder.java [99:108]
public ReactiveMessageSenderBuilder<T> clone() {
AdaptedReactiveMessageSenderBuilder<T> cloned = new AdaptedReactiveMessageSenderBuilder<>(this.schema,
this.reactiveProducerAdapterFactory, new MutableReactiveMessageSenderSpec(this.senderSpec));
cloned.producerCache = this.producerCache;
cloned.maxInflight = this.maxInflight;
cloned.maxConcurrentSenderSubscriptions = this.maxConcurrentSenderSubscriptions;
cloned.producerActionTransformer = this.producerActionTransformer;
cloned.stopOnError = this.stopOnError;
return cloned;
}