Toggle navigation
Home
java.util.Optional<org.apache.pulsar.client.api.MessageId> to org.apache.pulsar.client.api.MessageId
No. of Instances - 1
No. of Commits - 1
No. of Projects - {'pulsar'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Jdk -> Internal
Mapping:
Other
new PhaseOneResult(firstMessageId.get(),lastMessageId.get(),latestForKey)
to
scheduler
Add or Remove Method invocation
phaseOneLoop(reader,Optional.of(firstMessageId.orElse(id)),Optional.of(id),latestForKey,loopPromise)
to
phaseOneLoop(reader,Optional.of(firstMessageId.orElse(id)),lastMessageId,latestForKey,loopPromise)
Rename Method invocation
whenComplete
to
whenCompleteAsync