- java.lang.Object
-
- swim.runtime.AbstractUplinkContext
-
- swim.runtime.warp.WarpUplinkModem
-
- All Implemented Interfaces:
Link
,Uplink
,WarpLink
,WarpUplink
,Observable<Object>
,LinkContext
,WarpContext
,Log
- Direct Known Subclasses:
DemandUplinkModem
,ListUplinkModem
,PartialUplinkModem
,SupplyUplinkModem
public abstract class WarpUplinkModem extends AbstractUplinkContext implements WarpContext, WarpUplink
-
-
Field Summary
Fields Modifier and Type Field Description protected WarpBinding
linkBinding
protected Value
linkKey
protected int
status
-
Fields inherited from class swim.runtime.AbstractUplinkContext
observers
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
WarpUplinkModem(WarpBinding linkBinding)
protected
WarpUplinkModem(WarpBinding linkBinding, Value linkKey)
-
Method Summary
-
Methods inherited from class swim.runtime.AbstractUplinkContext
cipherSuite, cipherSuiteUp, close, closeUp, debug, debugUp, didCloseDown, didFail, didOpenDown, error, errorUp, 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
cipherSuiteUp, closeUp, debugUp, didCloseDown, didOpenDown, errorUp, infoUp, isConnectedUp, isRemoteUp, isSecureUp, localAddressUp, localCertificatesUp, localIdentityUp, localPrincipalUp, remoteAddressUp, remoteCertificatesUp, remoteIdentityUp, remotePrincipalUp, securityProtocolUp, traceUp, unwrapLink, warnUp
-
-
-
-
Field Detail
-
linkBinding
protected final WarpBinding linkBinding
-
linkKey
protected final Value linkKey
-
status
protected volatile int status
-
-
Constructor Detail
-
WarpUplinkModem
protected WarpUplinkModem(WarpBinding linkBinding, Value linkKey)
-
WarpUplinkModem
protected WarpUplinkModem(WarpBinding linkBinding)
-
-
Method Detail
-
linkWrapper
public final WarpBinding linkWrapper()
- Specified by:
linkWrapper
in interfaceLinkContext
- Specified by:
linkWrapper
in interfaceWarpContext
- Specified by:
linkWrapper
in classAbstractUplinkContext
-
linkBinding
public final WarpBinding linkBinding()
- Specified by:
linkBinding
in classAbstractUplinkContext
-
hostUri
public final Uri hostUri()
- Specified by:
hostUri
in interfaceLink
- Specified by:
hostUri
in classAbstractUplinkContext
-
nodeUri
public final Uri nodeUri()
- Specified by:
nodeUri
in interfaceLink
- Specified by:
nodeUri
in classAbstractUplinkContext
-
laneUri
public final Uri laneUri()
- Specified by:
laneUri
in interfaceLink
- Specified by:
laneUri
in classAbstractUplinkContext
-
linkKey
public final Value linkKey()
- Specified by:
linkKey
in interfaceLinkContext
- Specified by:
linkKey
in classAbstractUplinkContext
-
prio
public final float prio()
- Specified by:
prio
in interfaceWarpUplink
-
rate
public final float rate()
- Specified by:
rate
in interfaceWarpUplink
-
body
public final Value body()
- Specified by:
body
in interfaceWarpUplink
-
observe
public WarpUplinkModem observe(Object observer)
- Specified by:
observe
in interfaceLink
- Specified by:
observe
in interfaceObservable<Object>
- Specified by:
observe
in interfaceUplink
- Specified by:
observe
in interfaceWarpUplink
- Overrides:
observe
in classAbstractUplinkContext
-
unobserve
public WarpUplinkModem unobserve(Object observer)
- Specified by:
unobserve
in interfaceLink
- Specified by:
unobserve
in interfaceObservable<Object>
- Specified by:
unobserve
in interfaceUplink
- Specified by:
unobserve
in interfaceWarpUplink
- Overrides:
unobserve
in classAbstractUplinkContext
-
onEvent
public WarpUplinkModem onEvent(OnEventMessage onEvent)
- Specified by:
onEvent
in interfaceWarpUplink
-
onCommand
public WarpUplinkModem onCommand(OnCommandMessage onCommand)
- Specified by:
onCommand
in interfaceWarpUplink
-
onLink
public WarpUplinkModem onLink(OnLinkRequest onLink)
- Specified by:
onLink
in interfaceWarpUplink
-
onLinked
public WarpUplinkModem onLinked(OnLinkedResponse onLinked)
- Specified by:
onLinked
in interfaceWarpUplink
-
onSync
public WarpUplinkModem onSync(OnSyncRequest onSync)
- Specified by:
onSync
in interfaceWarpUplink
-
onSynced
public WarpUplinkModem onSynced(OnSyncedResponse onSynced)
- Specified by:
onSynced
in interfaceWarpUplink
-
onUnlink
public WarpUplinkModem onUnlink(OnUnlinkRequest onUnlink)
- Specified by:
onUnlink
in interfaceWarpUplink
-
onUnlinked
public WarpUplinkModem onUnlinked(OnUnlinkedResponse onUnlinked)
- Specified by:
onUnlinked
in interfaceWarpUplink
-
didClose
public WarpUplinkModem didClose(DidClose didClose)
- Specified by:
didClose
in interfaceWarpUplink
-
dispatchOnEvent
protected void dispatchOnEvent(EventMessage message)
-
dispatchOnCommand
protected boolean dispatchOnCommand(CommandMessage message, boolean preemptive)
-
dispatchOnLink
protected boolean dispatchOnLink(LinkRequest request, boolean preemptive)
-
dispatchOnLinked
protected void dispatchOnLinked(LinkedResponse response)
-
dispatchOnSync
protected boolean dispatchOnSync(SyncRequest request, boolean preemptive)
-
dispatchOnSynced
protected void dispatchOnSynced(SyncedResponse response)
-
dispatchOnUnlink
protected boolean dispatchOnUnlink(UnlinkRequest request, boolean preemptive)
-
dispatchOnUnlinked
protected void dispatchOnUnlinked(UnlinkedResponse response)
-
dispatchDidClose
protected void dispatchDidClose()
-
downQueueIsEmpty
protected boolean downQueueIsEmpty()
-
queueDown
protected void queueDown(Value body)
-
nextDownQueue
protected Value nextDownQueue()
-
nextDownQueueEvent
protected EventMessage nextDownQueueEvent()
-
nextDownCue
protected Value nextDownCue()
-
nextDownCueEvent
protected EventMessage nextDownCueEvent()
-
sendDown
public void sendDown(Value body)
-
cueDown
public void cueDown()
-
pullDown
public void pullDown()
- Specified by:
pullDown
in interfaceWarpContext
-
runPullDown
protected void runPullDown()
-
pullDownEnvelope
protected void pullDownEnvelope()
-
pullDownEvent
protected void pullDownEvent(EventMessage message)
-
pullDownLinked
protected void pullDownLinked(LinkedResponse response)
-
pullDownSynced
protected void pullDownSynced(SyncedResponse response)
-
pullDownUnlinked
protected void pullDownUnlinked(UnlinkedResponse response)
-
cueUp
public void cueUp()
-
feedUp
public void feedUp()
- Specified by:
feedUp
in interfaceWarpContext
-
pushUp
public void pushUp(Envelope envelope)
- Specified by:
pushUp
in interfaceWarpContext
-
pushUpCommand
protected void pushUpCommand(CommandMessage message)
-
runOnCommand
protected void runOnCommand(CommandMessage message)
-
pushUpLink
protected void pushUpLink(LinkRequest request)
-
runOnLink
protected void runOnLink(LinkRequest request)
-
pushUpSync
protected void pushUpSync(SyncRequest request)
-
runOnSync
protected void runOnSync(SyncRequest request)
-
pushUpUnlink
protected void pushUpUnlink(UnlinkRequest request)
-
runOnUnlink
protected void runOnUnlink(UnlinkRequest request)
-
pushUpEnvelope
protected void pushUpEnvelope(Envelope envelope)
-
skipUp
public void skipUp()
- Specified by:
skipUp
in interfaceWarpContext
-
unlink
public void unlink()
-
onEvent
protected void onEvent(EventMessage message)
-
onCommand
protected void onCommand(CommandMessage message)
-
willLink
protected void willLink(LinkRequest request)
-
didLink
protected void didLink(LinkedResponse response)
-
willSync
protected void willSync(SyncRequest request)
-
didSync
protected void didSync(SyncedResponse response)
-
willUnlink
protected void willUnlink(UnlinkRequest request)
-
didUnlink
protected void didUnlink(UnlinkedResponse response)
-
linkedResponse
protected LinkedResponse linkedResponse()
-
syncedResponse
protected SyncedResponse syncedResponse()
-
unlinkedResponse
protected UnlinkedResponse unlinkedResponse()
-
-