- java.lang.Object
-
- swim.system.AbstractUplinkContext
-
- swim.system.warp.WarpUplinkModem
-
- swim.system.warp.MapUplinkModem
-
- swim.system.lane.JoinValueLaneUplink
-
- All Implemented Interfaces:
Link
,Uplink
,WarpLink
,WarpUplink
,Observable<Object>
,LinkContext
,WarpContext
,Log
public class JoinValueLaneUplink extends MapUplinkModem
-
-
Field Summary
-
Fields inherited from class swim.system.warp.WarpUplinkModem
linkBinding, status, uplinkAddress
-
Fields inherited from class swim.system.AbstractUplinkContext
observers
-
-
Constructor Summary
Constructors Constructor Description JoinValueLaneUplink(JoinValueLaneModel laneBinding, WarpBinding linkBinding, UplinkAddress uplinkAddress)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description JoinValueLaneModel
laneBinding()
protected Value
nextDownKey(Value key)
Stage
stage()
protected void
willSync(SyncRequest request)
-
Methods inherited from class swim.system.warp.MapUplinkModem
cueDownKey, downQueueIsEmpty, nextDownCue, nextDownQueue, queueDown, syncDown
-
Methods inherited from class swim.system.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, willUnlink
-
Methods inherited from class swim.system.AbstractUplinkContext
bottomLink, cipherSuite, cipherSuiteUp, close, closeUp, debug, debugUp, didCloseDown, didFail, didFailDown, didOpenDown, error, errorUp, fail, failUp, info, infoUp, isConnected, isConnectedUp, isRemote, isRemoteUp, isSecure, isSecureUp, localAddress, localAddressUp, localCertificates, localCertificatesUp, localIdentity, localIdentityUp, localPrincipal, localPrincipalUp, remoteAddress, remoteAddressUp, remoteCertificates, remoteCertificatesUp, remoteIdentity, remoteIdentityUp, remotePrincipal, remotePrincipalUp, securityProtocol, securityProtocolUp, 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.system.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
-
JoinValueLaneUplink
public JoinValueLaneUplink(JoinValueLaneModel laneBinding, WarpBinding linkBinding, UplinkAddress uplinkAddress)
-
-
Method Detail
-
laneBinding
public JoinValueLaneModel laneBinding()
- Specified by:
laneBinding
in classAbstractUplinkContext
-
stage
public Stage stage()
- Specified by:
stage
in classAbstractUplinkContext
-
nextDownKey
protected Value nextDownKey(Value key)
- Specified by:
nextDownKey
in classMapUplinkModem
-
willSync
protected void willSync(SyncRequest request)
- Overrides:
willSync
in classWarpUplinkModem
-
-