pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ImmutableReactiveMessageReaderSpec.java [76:88]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
		this.readerName = readerSpec.getReaderName();
		this.subscriptionName = readerSpec.getSubscriptionName();
		this.generatedSubscriptionNamePrefix = readerSpec.getGeneratedSubscriptionNamePrefix();
		this.receiverQueueSize = readerSpec.getReceiverQueueSize();
		this.readCompacted = readerSpec.getReadCompacted();
		this.keyHashRanges = readerSpec.getKeyHashRanges();
		this.cryptoKeyReader = readerSpec.getCryptoKeyReader();
		this.cryptoFailureAction = readerSpec.getCryptoFailureAction();
	}

	@Override
	public List<String> getTopicNames() {
		return this.topicNames;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageReaderSpec.java [67:79]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
		this.readerName = readerSpec.getReaderName();
		this.subscriptionName = readerSpec.getSubscriptionName();
		this.generatedSubscriptionNamePrefix = readerSpec.getGeneratedSubscriptionNamePrefix();
		this.receiverQueueSize = readerSpec.getReceiverQueueSize();
		this.readCompacted = readerSpec.getReadCompacted();
		this.keyHashRanges = readerSpec.getKeyHashRanges();
		this.cryptoKeyReader = readerSpec.getCryptoKeyReader();
		this.cryptoFailureAction = readerSpec.getCryptoFailureAction();
	}

	@Override
	public List<String> getTopicNames() {
		return this.topicNames;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -