- java.lang.Object
-
- swim.runtime.AbstractUplinkContext
-
- swim.runtime.warp.WarpUplinkModem
-
- swim.runtime.warp.MapUplinkModem
-
- All Implemented Interfaces:
Link,Uplink,WarpLink,WarpUplink,Observable<Object>,LinkContext,WarpContext,Log
- Direct Known Subclasses:
DemandMapLaneUplink,JoinMapLaneUplink,JoinValueLaneUplink,MapLaneUplink,SpatialLaneUplink
public abstract class MapUplinkModem extends WarpUplinkModem
-
-
Field Summary
-
Fields inherited from class swim.runtime.warp.WarpUplinkModem
linkBinding, status, uplinkAddress
-
Fields inherited from class swim.runtime.AbstractUplinkContext
observers
-
-
Constructor Summary
Constructors Constructor Description MapUplinkModem(WarpBinding linkBinding, UplinkAddress uplinkAddress)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description voidcueDownKey(Value key)protected booleandownQueueIsEmpty()protected ValuenextDownCue()protected abstract ValuenextDownKey(Value key)protected ValuenextDownQueue()protected voidqueueDown(Value body)voidsyncDown(Iterator<Value> syncQueue)-
Methods inherited from class swim.runtime.warp.WarpUplinkModem
body, cellAddressUp, collectProfile, cueDown, cueUp, didClose, didClose, didLink, didSync, didUnlink, didUpdateMetrics, dispatchDidClose, dispatchOnCommand, dispatchOnEvent, dispatchOnLink, dispatchOnLinked, dispatchOnSync, dispatchOnSynced, dispatchOnUnlink, dispatchOnUnlinked, feedUp, flushMetrics, hostUri, laneUri, linkBinding, linkedResponse, linkKey, linkWrapper, nextDownCueEvent, nextDownQueueEvent, nodeUri, observe, onCommand, onCommand, onEvent, onEvent, onLink, onLinked, onSync, onSynced, onUnlink, onUnlinked, openMetaUplink, prio, pullDown, pullDownEnvelope, pullDownEvent, pullDownLinked, pullDownSynced, pullDownUnlinked, pushDown, pushUp, pushUpCommand, pushUpLink, pushUpSync, pushUpUnknown, pushUpUnlink, rate, reportMetrics, runOnCommand, runOnLink, runOnSync, runOnUnlink, runPullDown, sendDown, skipUp, syncedResponse, unlink, unlinkedResponse, unobserve, willLink, willSync, willUnlink
-
Methods inherited from class swim.runtime.AbstractUplinkContext
bottomLink, cipherSuite, cipherSuiteUp, close, closeUp, debug, debugUp, didCloseDown, didFail, didFailDown, didOpenDown, error, errorUp, fail, failUp, info, infoUp, isConnected, isConnectedUp, isRemote, isRemoteUp, isSecure, isSecureUp, laneBinding, localAddress, localAddressUp, localCertificates, localCertificatesUp, localIdentity, localIdentityUp, localPrincipal, localPrincipalUp, remoteAddress, remoteAddressUp, remoteCertificates, remoteCertificatesUp, remoteIdentity, remoteIdentityUp, remotePrincipal, remotePrincipalUp, securityProtocol, securityProtocolUp, stage, trace, traceUp, unwrapLink, warn, warnUp
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface swim.api.Link
cipherSuite, close, isConnected, isRemote, isSecure, localAddress, localCertificates, localIdentity, localPrincipal, remoteAddress, remoteCertificates, remoteIdentity, remotePrincipal, securityProtocol
-
Methods inherited from interface swim.runtime.LinkContext
bottomLink, cipherSuiteUp, closeUp, debugUp, didCloseDown, didFailDown, didOpenDown, errorUp, failUp, infoUp, isConnectedUp, isRemoteUp, isSecureUp, localAddressUp, localCertificatesUp, localIdentityUp, localPrincipalUp, remoteAddressUp, remoteCertificatesUp, remoteIdentityUp, remotePrincipalUp, securityProtocolUp, traceUp, unwrapLink, warnUp
-
-
-
-
Constructor Detail
-
MapUplinkModem
public MapUplinkModem(WarpBinding linkBinding, UplinkAddress uplinkAddress)
-
-
Method Detail
-
downQueueIsEmpty
protected boolean downQueueIsEmpty()
- Overrides:
downQueueIsEmptyin classWarpUplinkModem
-
queueDown
protected void queueDown(Value body)
- Overrides:
queueDownin classWarpUplinkModem
-
cueDownKey
public void cueDownKey(Value key)
-
nextDownQueue
protected Value nextDownQueue()
- Overrides:
nextDownQueuein classWarpUplinkModem
-
nextDownCue
protected Value nextDownCue()
- Overrides:
nextDownCuein classWarpUplinkModem
-
-