- All Superinterfaces:
Downlink
,Inlet<Map<K,
,V>> Iterable<Map.Entry<K,
,V>> IterableMap<K,
,V> Link
,Log
,Map<K,
,V> MapInlet<K,
,V, Map<K, V>> MapOutlet<K,
,V, MapDownlink<K, V>> Observable<Object>
,ObservableIterableMap<K,
,V> ObservableMap<K,
,V> ObservableOrderedMap<K,
,V> ObservableSortedMap<K,
,V> OrderedMap<K,
,V> Outlet<MapDownlink<K,
,V>> SortedMap<K,
,V> WarpDownlink
,WarpLink
- All Known Implementing Classes:
JoinMapLaneDownlink
,MapDownlinkView
public interface MapDownlink<K,V>
extends WarpDownlink, ObservableOrderedMap<K,V>, MapInlet<K,V,Map<K,V>>, MapOutlet<K,V,MapDownlink<K,V>>
-
Nested Class Summary
-
Method Summary
Modifier and TypeMethodDescriptiondidConnect
(DidConnect didConnect) didDisconnect
(DidDisconnect didDisconnect) didReceive
(DidReceive didReceive) didRemove
(DidRemoveKey<K, V> didRemove) didUpdate
(DidUpdateKey<K, V> didUpdate) boolean
isStateful
(boolean isStateful) keepLinked
(boolean keepLinked) keepSynced
(boolean keepSynced) <K2> MapDownlink<K2,
V> keyForm()
<K2> MapDownlink<K2,
V> Returns anIterator
over the keys in the current state of thisMapOutlet
.open()
prio
(float prio) rate
(float rate) <V2> MapDownlink<K,
V2> valueClass
(Class<V2> valueClass) <V2> MapDownlink<K,
V2> willCommand
(WillCommand willCommand) willReceive
(WillReceive willReceive) willRemove
(WillRemoveKey<K> willRemove) willUnlink
(WillUnlink willUnlink) willUpdate
(WillUpdateKey<K, V> willUpdate) Methods inherited from interface swim.streamlet.Inlet
bindInput, decohereOutput, disconnectInputs, disconnectOutputs, input, recohereOutput, unbindInput
Methods inherited from interface java.lang.Iterable
forEach, spliterator
Methods inherited from interface swim.api.Link
cipherSuite, close, hostUri, isConnected, isRemote, isSecure, laneUri, localAddress, localCertificates, localIdentity, localPrincipal, nodeUri, remoteAddress, remoteCertificates, remoteIdentity, remotePrincipal, securityProtocol
Methods inherited from interface java.util.Map
compute, computeIfAbsent, computeIfPresent, equals, forEach, getOrDefault, hashCode, merge, putIfAbsent, remove, replace, replace, replaceAll
Methods inherited from interface swim.streamlet.MapInlet
decohereOutputKey, recohereOutputKey
Methods inherited from interface swim.streamlet.MapOutlet
containsKey, decohereInputKey, filter, get, map, memoize, outlet, recohereInputKey, reduce, watch
Methods inherited from interface swim.observable.ObservableSortedMap
drop, take
Methods inherited from interface swim.util.OrderedMap
clear, comparator, containsKey, containsValue, entrySet, firstEntry, firstKey, firstValue, get, getEntry, getIndex, headMap, indexOf, isEmpty, iterator, keySet, lastEntry, lastKey, lastValue, nextEntry, nextKey, nextValue, previousEntry, previousKey, previousValue, put, putAll, remove, size, subMap, tailMap, valueIterator, values
Methods inherited from interface swim.streamlet.Outlet
bindOutput, decohereInput, disconnectInputs, disconnectOutputs, get, map, outputIterator, recohereInput, unbindOutput, unbindOutputs, watch
Methods inherited from interface swim.api.warp.WarpDownlink
body, command, command, command, command, keepLinked, keepSynced, prio, rate
-
Method Details
-
hostUri
- Specified by:
hostUri
in interfaceWarpDownlink
-
hostUri
- Specified by:
hostUri
in interfaceWarpDownlink
-
nodeUri
- Specified by:
nodeUri
in interfaceWarpDownlink
-
nodeUri
- Specified by:
nodeUri
in interfaceWarpDownlink
-
laneUri
- Specified by:
laneUri
in interfaceWarpDownlink
-
laneUri
- Specified by:
laneUri
in interfaceWarpDownlink
-
prio
- Specified by:
prio
in interfaceWarpDownlink
-
rate
- Specified by:
rate
in interfaceWarpDownlink
-
body
- Specified by:
body
in interfaceWarpDownlink
-
keepLinked
- Specified by:
keepLinked
in interfaceWarpDownlink
-
keepSynced
- Specified by:
keepSynced
in interfaceWarpDownlink
-
isStateful
boolean isStateful() -
isStateful
-
keyForm
-
keyForm
-
keyClass
-
valueForm
-
valueForm
-
valueClass
-
observe
- Specified by:
observe
in interfaceDownlink
- Specified by:
observe
in interfaceLink
- Specified by:
observe
in interfaceObservable<K>
- Specified by:
observe
in interfaceObservableMap<K,
V> - Specified by:
observe
in interfaceObservableSortedMap<K,
V> - Specified by:
observe
in interfaceWarpDownlink
-
unobserve
- Specified by:
unobserve
in interfaceDownlink
- Specified by:
unobserve
in interfaceLink
- Specified by:
unobserve
in interfaceObservable<K>
- Specified by:
unobserve
in interfaceObservableMap<K,
V> - Specified by:
unobserve
in interfaceObservableSortedMap<K,
V> - Specified by:
unobserve
in interfaceWarpDownlink
-
willUpdate
- Specified by:
willUpdate
in interfaceObservableMap<K,
V>
-
didUpdate
- Specified by:
didUpdate
in interfaceObservableMap<K,
V>
-
willRemove
- Specified by:
willRemove
in interfaceObservableMap<K,
V>
-
didRemove
- Specified by:
didRemove
in interfaceObservableMap<K,
V>
-
willDrop
- Specified by:
willDrop
in interfaceObservableSortedMap<K,
V>
-
didDrop
- Specified by:
didDrop
in interfaceObservableSortedMap<K,
V>
-
willTake
- Specified by:
willTake
in interfaceObservableSortedMap<K,
V>
-
didTake
- Specified by:
didTake
in interfaceObservableSortedMap<K,
V>
-
willClear
- Specified by:
willClear
in interfaceObservableMap<K,
V>
-
didClear
- Specified by:
didClear
in interfaceObservableMap<K,
V>
-
willReceive
- Specified by:
willReceive
in interfaceWarpDownlink
-
didReceive
- Specified by:
didReceive
in interfaceWarpDownlink
-
willCommand
- Specified by:
willCommand
in interfaceWarpDownlink
-
willLink
- Specified by:
willLink
in interfaceWarpDownlink
-
didLink
- Specified by:
didLink
in interfaceWarpDownlink
-
willSync
- Specified by:
willSync
in interfaceWarpDownlink
-
didSync
- Specified by:
didSync
in interfaceWarpDownlink
-
willUnlink
- Specified by:
willUnlink
in interfaceWarpDownlink
-
didUnlink
- Specified by:
didUnlink
in interfaceWarpDownlink
-
didConnect
- Specified by:
didConnect
in interfaceDownlink
- Specified by:
didConnect
in interfaceWarpDownlink
-
didDisconnect
- Specified by:
didDisconnect
in interfaceDownlink
- Specified by:
didDisconnect
in interfaceWarpDownlink
-
didClose
- Specified by:
didClose
in interfaceDownlink
- Specified by:
didClose
in interfaceWarpDownlink
-
didFail
- Specified by:
didFail
in interfaceDownlink
- Specified by:
didFail
in interfaceWarpDownlink
-
open
MapDownlink<K,V> open()- Specified by:
open
in interfaceDownlink
- Specified by:
open
in interfaceWarpDownlink
-
keyIterator
Description copied from interface:MapOutlet
Returns anIterator
over the keys in the current state of thisMapOutlet
.- Specified by:
keyIterator
in interfaceIterableMap<K,
V> - Specified by:
keyIterator
in interfaceMapOutlet<K,
V, MapDownlink<K, V>> - Specified by:
keyIterator
in interfaceOrderedMap<K,
V>
-