Toggle navigation
Home
io.atomix.core.map.DistributedTreeMap to io.atomix.core.map.DistributedNavigableMap
No. of Instances - 8
No. of Commits - 1
No. of Projects - {'atomix'}
Hierarchy/Composition: R_SUPER_T
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Rename Variable
getTreeMap
to
getNavigableMap
getTreeMap
to
getNavigableMap
Cascading Type Change (Different)
GossipDistributedTreeMap<>
to
GossipDistributedNavigableMap<>
DelegatingAsyncDistributedTreeMap<>
to
DelegatingAsyncDistributedNavigableMap<>
Add or Remove Method invocation
managementService.getPrimitiveCache().getPrimitive(name,() -> CompletableFuture.completedFuture(((TreeMapProtocolProvider)protocol).<K,V>newTreeMapProtocol(name,managementService)).thenApply(set -> new GossipDistributedNavigableMap<>(name,protocol,set)))
to
managementService.getPrimitiveCache().getPrimitive(name,() -> CompletableFuture.completedFuture(((NavigableMapProtocolProvider)protocol).<K,V>newNavigableMapProtocol(name,managementService)).thenApply(set -> new GossipDistributedNavigableMap<>(name,protocol,set)))
newProxy(AtomicTreeMapService.class,new ServiceConfig()).thenCompose(proxy -> new AtomicTreeMapProxy<K>((ProxyClient)proxy,managementService.getPrimitiveRegistry()).connect()).thenApply(map -> { Serializer serializer=protocol.serializer(); return new TranscodingAsyncAtomicTreeMap<K,V,byte[]>(map,value -> serializer.encode(value),bytes -> serializer.decode(bytes)); } )
to
newProxy(AtomicTreeMapService.class,new ServiceConfig()).thenCompose(proxy -> new AtomicNavigableMapProxy<K>((ProxyClient)proxy,managementService.getPrimitiveRegistry()).connect()).thenApply(map -> { Serializer serializer=protocol.serializer(); return new TranscodingAsyncAtomicNavigableMap<K,V,byte[]>(map,value -> serializer.encode(value),bytes -> serializer.decode(bytes)); } )