- java.lang.Object
-
- swim.runtime.uplink.UplinkModem
-
- swim.runtime.uplink.PartialUplinkModem
-
- All Implemented Interfaces:
Link
,Uplink
,Observable<Object>
,LinkContext
,Log
- Direct Known Subclasses:
DemandMapLaneUplink
,JoinMapLaneUplink
,JoinValueLaneUplink
,MapLaneUplink
,SpatialLaneUplink
public abstract class PartialUplinkModem extends UplinkModem
-
-
Field Summary
-
Fields inherited from class swim.runtime.uplink.UplinkModem
linkBinding, linkKey, observers, status
-
-
Constructor Summary
Constructors Constructor Description PartialUplinkModem(LinkBinding linkBinding)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description void
cueDownKey(Value key)
protected boolean
downQueueIsEmpty()
protected Value
nextDownCue()
protected abstract Value
nextDownKey(Value key)
protected Value
nextDownQueue()
protected void
queueDown(Value body)
void
syncDown(Iterator<Map.Entry<Value,Value>> syncQueue)
-
Methods inherited from class swim.runtime.uplink.UplinkModem
body, cipherSuite, cipherSuiteUp, close, closeUp, cueDown, cueUp, debug, debugUp, didClose, didCloseDown, didFail, didLink, didOpenDown, didSync, didUnlink, dispatchDidClose, dispatchOnCommand, dispatchOnEvent, dispatchOnLink, dispatchOnLinked, dispatchOnSync, dispatchOnSynced, dispatchOnUnlink, dispatchOnUnlinked, error, errorUp, feedUp, hostUri, info, infoUp, isConnected, isConnectedUp, isRemote, isRemoteUp, isSecure, isSecureUp, laneBinding, laneUri, linkBinding, linkedResponse, linkKey, linkWrapper, localAddress, localAddressUp, localCertificates, localCertificatesUp, localIdentity, localIdentityUp, localPrincipal, localPrincipalUp, nextDownCueEvent, nextDownQueueEvent, nodeUri, observe, onCommand, onCommand, onEvent, onEvent, onLink, onLinked, onSync, onSynced, onUnlink, onUnlinked, prio, pullDown, pullDownEnvelope, pullDownEvent, pullDownLinked, pullDownSynced, pullDownUnlinked, pushUp, pushUpCommand, pushUpEnvelope, pushUpLink, pushUpSync, pushUpUnlink, rate, remoteAddress, remoteAddressUp, remoteCertificates, remoteCertificatesUp, remoteIdentity, remoteIdentityUp, remotePrincipal, remotePrincipalUp, runOnCommand, runOnLink, runOnSync, runOnUnlink, runPullDown, securityProtocol, securityProtocolUp, sendDown, skipUp, stage, syncedResponse, trace, traceUp, unlink, unlinkedResponse, unobserve, unwrapLink, warn, warnUp, willLink, willSync, willUnlink
-
-
-
-
Constructor Detail
-
PartialUplinkModem
public PartialUplinkModem(LinkBinding linkBinding)
-
-
Method Detail
-
downQueueIsEmpty
protected boolean downQueueIsEmpty()
- Overrides:
downQueueIsEmpty
in classUplinkModem
-
queueDown
protected void queueDown(Value body)
- Overrides:
queueDown
in classUplinkModem
-
cueDownKey
public void cueDownKey(Value key)
-
nextDownQueue
protected Value nextDownQueue()
- Overrides:
nextDownQueue
in classUplinkModem
-
nextDownCue
protected Value nextDownCue()
- Overrides:
nextDownCue
in classUplinkModem
-
-