Module swim.system

Package swim.system.lane

Class JoinValueLaneUplink

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

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

Methods inherited from interface swim.util.Log

debug, error, fail, info, trace, warn

Constructor Details

JoinValueLaneUplink

public JoinValueLaneUplink(JoinValueLaneModel laneBinding,
 WarpBinding linkBinding,
 UplinkAddress uplinkAddress)

Method Details

laneBinding

public JoinValueLaneModel laneBinding()

Specified by:

laneBinding in class AbstractUplinkContext

stage

public Stage stage()

Specified by:

stage in class AbstractUplinkContext

nextDownKey

protected Value nextDownKey(Value key)

Specified by:

nextDownKey in class MapUplinkModem

willSync

protected void willSync(SyncRequest request)

Overrides:

willSync in class WarpUplinkModem