java.lang.Object
swim.system.DownlinkView
swim.system.warp.WarpDownlinkView
swim.system.downlink.MapDownlinkView<K,V>
swim.system.lane.JoinMapLaneDownlink<K,V>
- All Implemented Interfaces:
Iterable<Map.Entry<K,
,V>> Map<K,
,V> SortedMap<K,
,V> Downlink
,MapDownlink<K,
,V> Link
,WarpDownlink
,WarpLink
,Observable<Object>
,ObservableIterableMap<K,
,V> ObservableMap<K,
,V> ObservableOrderedMap<K,
,V> ObservableSortedMap<K,
,V> Inlet<Map<K,
,V>> MapInlet<K,
,V, Map<K, V>> MapOutlet<K,
,V, MapDownlink<K, V>> Outlet<MapDownlink<K,
,V>> IterableMap<K,
,V> Log
,OrderedMap<K,
V>
-
Nested Class Summary
-
Field Summary
Fields inherited from class swim.system.downlink.MapDownlinkView
effects, input, keyForm, model, outlets, outputs, STATEFUL, valueForm, version
Fields inherited from class swim.system.warp.WarpDownlinkView
body, flags, hostUri, KEEP_LINKED, KEEP_SYNCED, laneUri, meshUri, nodeUri, prio, rate
Fields inherited from class swim.system.DownlinkView
cellContext, observers, stage
-
Constructor Summary
ConstructorDescriptionJoinMapLaneDownlink
(CellContext cellContext, Stage stage, JoinMapLaneModel laneModel, Value key, Uri meshUri, Uri hostUri, Uri nodeUri, Uri laneUri, float prio, float rate, Value body, int flags, Form<K> keyForm, Form<V> valueForm, Object observers) JoinMapLaneDownlink
(CellContext cellContext, Stage stage, JoinMapLaneModel laneModel, Value key, Uri meshUri, Uri hostUri, Uri nodeUri, Uri laneUri, float prio, float rate, Value body, Form<K> keyForm, Form<V> valueForm) -
Method Summary
Modifier and TypeMethodDescriptionvoid
void
downlinkDidDrop
(int lower) void
downlinkDidRemoveValue
(Value key, Value oldValue) void
downlinkDidTake
(int upper) void
downlinkDidUpdateValue
(Value key, Value newValue, Value oldValue) void
void
downlinkWillDrop
(int lower) void
void
downlinkWillTake
(int upper) downlinkWillUpdateValue
(Value key, Value newValue) <K2> MapDownlinkView<K2,
V> open()
protected void
prio
(float prio) rate
(float rate) <V2> MapDownlinkView<K,
V2> Methods inherited from class swim.system.downlink.MapDownlinkView
bindInput, bindInput, bindOutput, clear, close, comparator, containsKey, containsValue, createDownlinkModel, decohere, decohereInput, decohereInputKey, decohereKey, decohereOutput, decohereOutputKey, didClear, didClose, didConnect, didDecohere, didDecohereKey, didDisconnect, didDrop, didFail, didLink, didReceive, didRecohere, didRecohereKey, didRemove, didSync, didTake, didUnlink, didUpdate, disconnectInputs, disconnectOutputs, dispatchDidClear, dispatchDidDrop, dispatchDidRemove, dispatchDidTake, dispatchDidUpdate, dispatchWillClear, dispatchWillDrop, dispatchWillRemove, dispatchWillTake, dispatchWillUpdate, downlinkDidRemove, downlinkDidUpdate, downlinkModel, downlinkWillRemove, downlinkWillUpdate, drop, entrySet, firstEntry, firstKey, firstValue, get, get, getEntry, getIndex, headMap, hostUri, indexOf, input, isEmpty, isStateful, isStateful, iterator, keepLinked, keepSynced, keyClass, keyForm, keyIterator, keySet, laneUri, lastEntry, lastKey, lastValue, nextEntry, nextKey, nextValue, nodeUri, observe, onDecohere, onDecohereKey, onRecohere, onRecohereKey, outlet, outputIterator, previousEntry, previousKey, previousValue, put, putAll, recohere, recohereInput, recohereInputKey, recohereKey, recohereOutput, recohereOutputKey, remove, size, subMap, tailMap, take, typesafeObservers, unbindInput, unbindOutput, unbindOutputs, unobserve, valueClass, valueForm, valueIterator, values, willClear, willCommand, willDecohere, willDecohereKey, willDrop, willLink, willReceive, willRecohere, willRecohereKey, willRemove, willSync, willTake, willUnlink, willUpdate
Methods inherited from class swim.system.warp.WarpDownlinkView
body, command, command, command, command, dispatchDidLink, dispatchDidReceive, dispatchDidSync, dispatchDidUnlink, dispatchWillCommand, dispatchWillLink, dispatchWillReceive, dispatchWillSync, dispatchWillUnlink, downlinkDidLink, downlinkDidReceive, downlinkDidSync, downlinkDidUnlink, downlinkWillCommand, downlinkWillLink, downlinkWillReceive, downlinkWillSync, downlinkWillUnlink, hostUri, keepLinked, keepSynced, laneUri, meshUri, nodeUri, prio, rate
Methods inherited from class swim.system.DownlinkView
cellContext, cipherSuite, debug, dispatchDidClose, dispatchDidConnect, dispatchDidDisconnect, dispatchDidFail, downlinkDidClose, downlinkDidConnect, downlinkDidDisconnect, downlinkDidFail, error, fail, info, isConnected, isRemote, isSecure, localAddress, localCertificates, localIdentity, localPrincipal, remoteAddress, remoteCertificates, remoteIdentity, remotePrincipal, securityProtocol, stage, trace, warn
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface java.lang.Iterable
forEach, spliterator
Methods inherited from interface swim.api.Link
cipherSuite, 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.api.warp.WarpDownlink
body, command, command, command, command, keepLinked, keepSynced, prio, rate
-
Field Details
-
laneModel
-
key
-
-
Constructor Details
-
JoinMapLaneDownlink
-
JoinMapLaneDownlink
-
-
Method Details
-
hostUri
- Specified by:
hostUri
in interfaceMapDownlink<K,
V> - Specified by:
hostUri
in interfaceWarpDownlink
- Overrides:
hostUri
in classMapDownlinkView<K,
V>
-
nodeUri
- Specified by:
nodeUri
in interfaceMapDownlink<K,
V> - Specified by:
nodeUri
in interfaceWarpDownlink
- Overrides:
nodeUri
in classMapDownlinkView<K,
V>
-
laneUri
- Specified by:
laneUri
in interfaceMapDownlink<K,
V> - Specified by:
laneUri
in interfaceWarpDownlink
- Overrides:
laneUri
in classMapDownlinkView<K,
V>
-
prio
- Specified by:
prio
in interfaceMapDownlink<K,
V> - Specified by:
prio
in interfaceWarpDownlink
- Overrides:
prio
in classMapDownlinkView<K,
V>
-
rate
- Specified by:
rate
in interfaceMapDownlink<K,
V> - Specified by:
rate
in interfaceWarpDownlink
- Overrides:
rate
in classMapDownlinkView<K,
V>
-
body
- Specified by:
body
in interfaceMapDownlink<K,
V> - Specified by:
body
in interfaceWarpDownlink
- Overrides:
body
in classMapDownlinkView<K,
V>
-
keyForm
- Specified by:
keyForm
in interfaceMapDownlink<K,
V> - Overrides:
keyForm
in classMapDownlinkView<K,
V>
-
valueForm
- Specified by:
valueForm
in interfaceMapDownlink<K,
V> - Overrides:
valueForm
in classMapDownlinkView<K,
V>
-
downlinkWillUpdateValue
- Overrides:
downlinkWillUpdateValue
in classMapDownlinkView<K,
V>
-
downlinkDidUpdateValue
- Overrides:
downlinkDidUpdateValue
in classMapDownlinkView<K,
V>
-
downlinkWillRemoveValue
- Overrides:
downlinkWillRemoveValue
in classMapDownlinkView<K,
V>
-
downlinkDidRemoveValue
- Overrides:
downlinkDidRemoveValue
in classMapDownlinkView<K,
V>
-
downlinkWillDrop
public void downlinkWillDrop(int lower) - Overrides:
downlinkWillDrop
in classMapDownlinkView<K,
V>
-
downlinkDidDrop
public void downlinkDidDrop(int lower) - Overrides:
downlinkDidDrop
in classMapDownlinkView<K,
V>
-
downlinkWillTake
public void downlinkWillTake(int upper) - Overrides:
downlinkWillTake
in classMapDownlinkView<K,
V>
-
downlinkDidTake
public void downlinkDidTake(int upper) - Overrides:
downlinkDidTake
in classMapDownlinkView<K,
V>
-
downlinkWillClear
public void downlinkWillClear()- Overrides:
downlinkWillClear
in classMapDownlinkView<K,
V>
-
downlinkDidClear
public void downlinkDidClear()- Overrides:
downlinkDidClear
in classMapDownlinkView<K,
V>
-
open
- Specified by:
open
in interfaceDownlink
- Specified by:
open
in interfaceMapDownlink<K,
V> - Specified by:
open
in interfaceWarpDownlink
- Overrides:
open
in classMapDownlinkView<K,
V>
-
openDownlink
protected void openDownlink()
-