- java.lang.Object
-
- swim.runtime.uplink.UplinkModem
-
- swim.runtime.uplink.SeqUplinkModem
-
- All Implemented Interfaces:
Link
,Uplink
,Observable<Object>
,LinkContext
,Log
- Direct Known Subclasses:
ListLaneUplink
public abstract class SeqUplinkModem extends UplinkModem
-
-
Field Summary
Fields Modifier and Type Field Description protected HashTrieMap<Value,ListOperation>
keyQueue
protected Iterator<Map.Entry<Value,Value>>
syncQueue
-
Fields inherited from class swim.runtime.uplink.UplinkModem
linkBinding, linkKey, observers, status
-
-
Constructor Summary
Constructors Constructor Description SeqUplinkModem(LinkBinding linkBinding)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description void
cueDownKey(Value key, ListOperation listOperation)
protected boolean
downQueueIsEmpty()
protected Value
nextDownCue()
protected abstract Value
nextDownKey(Value key, ListOperation listOperation)
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
-
-
-
-
Field Detail
-
keyQueue
protected volatile HashTrieMap<Value,ListOperation> keyQueue
-
-
Constructor Detail
-
SeqUplinkModem
public SeqUplinkModem(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, ListOperation listOperation)
-
nextDownKey
protected abstract Value nextDownKey(Value key, ListOperation listOperation)
-
nextDownQueue
protected Value nextDownQueue()
- Overrides:
nextDownQueue
in classUplinkModem
-
nextDownCue
protected Value nextDownCue()
- Overrides:
nextDownCue
in classUplinkModem
-
-