-
- 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>>
-
-
Method Summary
-
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 Detail
-
hostUri
MapDownlink<K,V> hostUri(Uri hostUri)
- Specified by:
hostUri
in interfaceWarpDownlink
-
hostUri
MapDownlink<K,V> hostUri(String hostUri)
- Specified by:
hostUri
in interfaceWarpDownlink
-
nodeUri
MapDownlink<K,V> nodeUri(Uri nodeUri)
- Specified by:
nodeUri
in interfaceWarpDownlink
-
nodeUri
MapDownlink<K,V> nodeUri(String nodeUri)
- Specified by:
nodeUri
in interfaceWarpDownlink
-
laneUri
MapDownlink<K,V> laneUri(Uri laneUri)
- Specified by:
laneUri
in interfaceWarpDownlink
-
laneUri
MapDownlink<K,V> laneUri(String laneUri)
- Specified by:
laneUri
in interfaceWarpDownlink
-
prio
MapDownlink<K,V> prio(float prio)
- Specified by:
prio
in interfaceWarpDownlink
-
rate
MapDownlink<K,V> rate(float rate)
- Specified by:
rate
in interfaceWarpDownlink
-
body
MapDownlink<K,V> body(Value body)
- Specified by:
body
in interfaceWarpDownlink
-
keepLinked
MapDownlink<K,V> keepLinked(boolean keepLinked)
- Specified by:
keepLinked
in interfaceWarpDownlink
-
keepSynced
MapDownlink<K,V> keepSynced(boolean keepSynced)
- Specified by:
keepSynced
in interfaceWarpDownlink
-
isStateful
boolean isStateful()
-
isStateful
MapDownlink<K,V> isStateful(boolean isStateful)
-
keyForm
<K2> MapDownlink<K2,V> keyForm(Form<K2> keyForm)
-
keyClass
<K2> MapDownlink<K2,V> keyClass(Class<K2> keyClass)
-
valueForm
<V2> MapDownlink<K,V2> valueForm(Form<V2> valueForm)
-
valueClass
<V2> MapDownlink<K,V2> valueClass(Class<V2> valueClass)
-
observe
MapDownlink<K,V> observe(Object observer)
- 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
MapDownlink<K,V> unobserve(Object observer)
- 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
MapDownlink<K,V> willUpdate(WillUpdateKey<K,V> willUpdate)
- Specified by:
willUpdate
in interfaceObservableMap<K,V>
-
didUpdate
MapDownlink<K,V> didUpdate(DidUpdateKey<K,V> didUpdate)
- Specified by:
didUpdate
in interfaceObservableMap<K,V>
-
willRemove
MapDownlink<K,V> willRemove(WillRemoveKey<K> willRemove)
- Specified by:
willRemove
in interfaceObservableMap<K,V>
-
didRemove
MapDownlink<K,V> didRemove(DidRemoveKey<K,V> didRemove)
- Specified by:
didRemove
in interfaceObservableMap<K,V>
-
willDrop
MapDownlink<K,V> willDrop(WillDrop willDrop)
- Specified by:
willDrop
in interfaceObservableSortedMap<K,V>
-
didDrop
MapDownlink<K,V> didDrop(DidDrop didDrop)
- Specified by:
didDrop
in interfaceObservableSortedMap<K,V>
-
willTake
MapDownlink<K,V> willTake(WillTake willTake)
- Specified by:
willTake
in interfaceObservableSortedMap<K,V>
-
didTake
MapDownlink<K,V> didTake(DidTake didTake)
- Specified by:
didTake
in interfaceObservableSortedMap<K,V>
-
willClear
MapDownlink<K,V> willClear(WillClear willClear)
- Specified by:
willClear
in interfaceObservableMap<K,V>
-
didClear
MapDownlink<K,V> didClear(DidClear didClear)
- Specified by:
didClear
in interfaceObservableMap<K,V>
-
willReceive
MapDownlink<K,V> willReceive(WillReceive willReceive)
- Specified by:
willReceive
in interfaceWarpDownlink
-
didReceive
MapDownlink<K,V> didReceive(DidReceive didReceive)
- Specified by:
didReceive
in interfaceWarpDownlink
-
willCommand
MapDownlink<K,V> willCommand(WillCommand willCommand)
- Specified by:
willCommand
in interfaceWarpDownlink
-
willLink
MapDownlink<K,V> willLink(WillLink willLink)
- Specified by:
willLink
in interfaceWarpDownlink
-
didLink
MapDownlink<K,V> didLink(DidLink didLink)
- Specified by:
didLink
in interfaceWarpDownlink
-
willSync
MapDownlink<K,V> willSync(WillSync willSync)
- Specified by:
willSync
in interfaceWarpDownlink
-
didSync
MapDownlink<K,V> didSync(DidSync didSync)
- Specified by:
didSync
in interfaceWarpDownlink
-
willUnlink
MapDownlink<K,V> willUnlink(WillUnlink willUnlink)
- Specified by:
willUnlink
in interfaceWarpDownlink
-
didUnlink
MapDownlink<K,V> didUnlink(DidUnlink didUnlink)
- Specified by:
didUnlink
in interfaceWarpDownlink
-
didConnect
MapDownlink<K,V> didConnect(DidConnect didConnect)
- Specified by:
didConnect
in interfaceDownlink
- Specified by:
didConnect
in interfaceWarpDownlink
-
didDisconnect
MapDownlink<K,V> didDisconnect(DidDisconnect didDisconnect)
- Specified by:
didDisconnect
in interfaceDownlink
- Specified by:
didDisconnect
in interfaceWarpDownlink
-
didClose
MapDownlink<K,V> didClose(DidClose didClose)
- Specified by:
didClose
in interfaceDownlink
- Specified by:
didClose
in interfaceWarpDownlink
-
didFail
MapDownlink<K,V> didFail(DidFail 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
Cursor<K> 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>
-
-