Module swim.runtime

Package swim.runtime.lane

Class JoinMapLaneDownlink<K,V>

java.lang.Object

swim.runtime.DownlinkView

swim.runtime.warp.WarpDownlinkView

swim.runtime.downlink.MapDownlinkView<K,V>

swim.runtime.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>

public class JoinMapLaneDownlink<K,V>
extends MapDownlinkView<K,V>

Nested Class Summary

Nested classes/interfaces inherited from interface java.util.Map

Map.Entry<K extends Object,V extends Object>

Field Summary

Fields

Modifier and Type	Field	Description
protected Value	key
protected JoinMapLaneModel	laneModel

Fields inherited from class swim.runtime.downlink.MapDownlinkView

effects, input, keyForm, model, outlets, outputs, STATEFUL, valueForm, version

Fields inherited from class swim.runtime.warp.WarpDownlinkView

body, flags, hostUri, KEEP_LINKED, KEEP_SYNCED, laneUri, meshUri, nodeUri, prio, rate

Fields inherited from class swim.runtime.DownlinkView

cellContext, observers, stage

Constructor Summary

Constructors

Constructor	Description
JoinMapLaneDownlink(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 Type	Method	Description
MapDownlinkView<K,V>	body(Value body)
void	downlinkDidClear()
void	downlinkDidDrop(int lower)
void	downlinkDidRemoveValue(Value key, Value oldValue)
void	downlinkDidTake(int upper)
void	downlinkDidUpdateValue(Value key, Value newValue, Value oldValue)
void	downlinkWillClear()
void	downlinkWillDrop(int lower)
void	downlinkWillRemoveValue(Value key)
void	downlinkWillTake(int upper)
Value	downlinkWillUpdateValue(Value key, Value newValue)
MapDownlinkView<K,V>	hostUri(Uri hostUri)
<K2> MapDownlinkView<K2,V>	keyForm(Form<K2> keyForm)
MapDownlinkView<K,V>	laneUri(Uri laneUri)
MapDownlinkView<K,V>	nodeUri(Uri nodeUri)
MapDownlinkView<K,V>	open()
protected void	openDownlink()
MapDownlinkView<K,V>	prio(float prio)
MapDownlinkView<K,V>	rate(float rate)
<V2> MapDownlinkView<K,V2>	valueForm(Form<V2> valueForm)

Methods inherited from class swim.runtime.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.runtime.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.runtime.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 swim.util.Log

debug, error, fail, info, trace, warn

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.MapOutlet

filter, map, memoize, reduce, watch

Methods inherited from interface swim.streamlet.Outlet

map, watch

Methods inherited from interface swim.api.warp.WarpDownlink

body, command, command, command, command, keepLinked, keepSynced, prio, rate

Field Detail

laneModel

protected final JoinMapLaneModel laneModel

key

protected final Value key

Constructor Detail

JoinMapLaneDownlink

public JoinMapLaneDownlink(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

public 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 Detail

hostUri

public MapDownlinkView<K,V> hostUri(Uri hostUri)

Specified by:

hostUri in interface MapDownlink<K,V>

Specified by:

hostUri in interface WarpDownlink

Overrides:

hostUri in class MapDownlinkView<K,V>

nodeUri

public MapDownlinkView<K,V> nodeUri(Uri nodeUri)

Specified by:

nodeUri in interface MapDownlink<K,V>

Specified by:

nodeUri in interface WarpDownlink

Overrides:

nodeUri in class MapDownlinkView<K,V>

laneUri

public MapDownlinkView<K,V> laneUri(Uri laneUri)

Specified by:

laneUri in interface MapDownlink<K,V>

Specified by:

laneUri in interface WarpDownlink

Overrides:

laneUri in class MapDownlinkView<K,V>

prio

public MapDownlinkView<K,V> prio(float prio)

Specified by:

prio in interface MapDownlink<K,V>

Specified by:

prio in interface WarpDownlink

Overrides:

prio in class MapDownlinkView<K,V>

rate

public MapDownlinkView<K,V> rate(float rate)

Specified by:

rate in interface MapDownlink<K,V>

Specified by:

rate in interface WarpDownlink

Overrides:

rate in class MapDownlinkView<K,V>

body

public MapDownlinkView<K,V> body(Value body)

Specified by:

body in interface MapDownlink<K,V>

Specified by:

body in interface WarpDownlink

Overrides:

body in class MapDownlinkView<K,V>

keyForm

public <K2> MapDownlinkView<K2,V> keyForm(Form<K2> keyForm)

Specified by:

keyForm in interface MapDownlink<K,V>

Overrides:

keyForm in class MapDownlinkView<K,V>

valueForm

public <V2> MapDownlinkView<K,V2> valueForm(Form<V2> valueForm)

Specified by:

valueForm in interface MapDownlink<K,V>

Overrides:

valueForm in class MapDownlinkView<K,V>

downlinkWillUpdateValue

public Value downlinkWillUpdateValue(Value key,
                                     Value newValue)

Overrides:

downlinkWillUpdateValue in class MapDownlinkView<K,V>

downlinkDidUpdateValue

public void downlinkDidUpdateValue(Value key,
                                   Value newValue,
                                   Value oldValue)

Overrides:

downlinkDidUpdateValue in class MapDownlinkView<K,V>

downlinkWillRemoveValue

public void downlinkWillRemoveValue(Value key)

Overrides:

downlinkWillRemoveValue in class MapDownlinkView<K,V>

downlinkDidRemoveValue

public void downlinkDidRemoveValue(Value key,
                                   Value oldValue)

Overrides:

downlinkDidRemoveValue in class MapDownlinkView<K,V>

downlinkWillDrop

public void downlinkWillDrop(int lower)

Overrides:

downlinkWillDrop in class MapDownlinkView<K,V>

downlinkDidDrop

public void downlinkDidDrop(int lower)

Overrides:

downlinkDidDrop in class MapDownlinkView<K,V>

downlinkWillTake

public void downlinkWillTake(int upper)

Overrides:

downlinkWillTake in class MapDownlinkView<K,V>

downlinkDidTake

public void downlinkDidTake(int upper)

Overrides:

downlinkDidTake in class MapDownlinkView<K,V>

downlinkWillClear

public void downlinkWillClear()

Overrides:

downlinkWillClear in class MapDownlinkView<K,V>

downlinkDidClear

public void downlinkDidClear()

Overrides:

downlinkDidClear in class MapDownlinkView<K,V>

open

public MapDownlinkView<K,V> open()

Specified by:

open in interface Downlink

Specified by:

open in interface MapDownlink<K,V>

Specified by:

open in interface WarpDownlink

Overrides:

open in class MapDownlinkView<K,V>

openDownlink

protected void openDownlink()