- java.lang.Object
-
- swim.runtime.AbstractSwimRef
-
- swim.runtime.AbstractTierBinding
-
- swim.runtime.lane.LaneView
-
- All Implemented Interfaces:
DownlinkFactory
,HttpLane<Object>
,Lane
,SwimRef
,Observable<Object>
,CellContext
,TierBinding
,Log
- Direct Known Subclasses:
CommandLaneView
,DemandLaneView
,DemandMapLaneView
,JoinMapLaneView
,JoinValueLaneView
,ListLaneView
,MapLaneView
,SpatialLaneView
,SupplyLaneView
,ValueLaneView
public abstract class LaneView extends AbstractTierBinding implements Lane
-
-
Field Summary
Fields Modifier and Type Field Description protected Object
observers
-
Fields inherited from class swim.runtime.AbstractTierBinding
CLOSED_PHASE, CLOSED_STATE, CLOSING_STATE, FAILED_STATE, FAILING_STATE, LOADED_PHASE, LOADED_STATE, LOADING_STATE, OPENED_PHASE, OPENED_STATE, OPENING_STATE, PHASE_MASK, PHASE_SHIFT, RECOVERING_STATE, STARTED_PHASE, STARTED_STATE, STARTING_STATE, STATE_MASK, status, STATUS, STOPPING_STATE, UNLOADING_STATE
-
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description abstract AgentContext
agentContext()
LinkBinding
bindDownlink(Downlink downlink)
abstract void
close()
void
closeDownlink(LinkBinding link)
abstract LaneBinding
createLaneBinding()
void
debug(Object message)
Logs a debug-level message.abstract LaneView
decodeRequest(DecodeRequestHttp<Object> decodeRequest)
abstract LaneView
didCommand(DidCommand didCommand)
abstract LaneView
didEnter(DidEnter didEnter)
abstract LaneView
didLeave(DidLeave didLeave)
abstract LaneView
didRequest(DidRequestHttp<Object> didRequest)
abstract LaneView
didRespond(DidRespondHttp<?> didRespond)
abstract LaneView
didUplink(DidUplink didUplink)
protected Decoder<Object>
dispatchDecodeRequest(HttpUplink uplink, HttpRequest<?> request)
protected boolean
dispatchDidCommand(Value body, boolean preemptive)
protected boolean
dispatchDidEnter(Identity identity, boolean preemptive)
protected boolean
dispatchDidLeave(Identity identity, boolean preemptive)
protected boolean
dispatchDidRequest(HttpUplink uplink, HttpRequest<Object> request, boolean preemptive)
protected boolean
dispatchDidRespond(HttpUplink uplink, HttpResponse<?> response, boolean preemptive)
protected boolean
dispatchDidUplink(Uplink uplink, boolean preemptive)
protected Object
dispatchDoRespond(HttpUplink uplink, HttpRequest<Object> request, boolean preemptive)
protected boolean
dispatchWillCommand(Value body, boolean preemptive)
protected boolean
dispatchWillEnter(Identity identity, boolean preemptive)
protected boolean
dispatchWillLeave(Identity identity, boolean preemptive)
protected boolean
dispatchWillRequest(HttpUplink uplink, HttpRequest<?> request, boolean preemptive)
protected boolean
dispatchWillRespond(HttpUplink uplink, HttpResponse<?> response, boolean preemptive)
protected boolean
dispatchWillUplink(Uplink uplink, boolean preemptive)
abstract LaneView
doRespond(DoRespondHttp<Object> doRespond)
void
error(Object message)
Logs an error-level message.Uri
hostUri()
void
httpDownlink(HttpBinding http)
void
info(Object message)
Logs an info-level message.abstract LaneBinding
laneBinding()
LaneContext
laneContext()
Decoder<Object>
laneDecodeRequest(HttpUplink uplink, HttpRequest<?> request)
void
laneDidCommand(CommandMessage message)
void
laneDidEnter(Identity identity)
void
laneDidFail(Throwable error)
void
laneDidLeave(Identity identity)
void
laneDidRequest(HttpUplink uplink, HttpRequest<Object> request)
void
laneDidRespond(HttpUplink uplink, HttpResponse<?> response)
void
laneDidUplink(Uplink uplink)
HttpResponse<?>
laneDoRespond(HttpUplink uplink, HttpRequest<Object> request)
Uri
laneUri()
void
laneWillCommand(CommandMessage message)
void
laneWillEnter(Identity identity)
void
laneWillLeave(Identity identity)
void
laneWillRequest(HttpUplink uplink, HttpRequest<?> request)
void
laneWillRespond(HttpUplink uplink, HttpResponse<?> response)
void
laneWillUplink(Uplink uplink)
Uri
meshUri()
Uri
nodeUri()
LaneView
observe(Object newObserver)
void
openDownlink(LinkBinding link)
Policy
policy()
void
pushDown(PushRequest pushRequest)
Schedule
schedule()
Stage
stage()
StoreBinding
store()
TierContext
tierContext()
void
trace(Object message)
Logs a trace-level message.LaneView
unobserve(Object oldObserver)
<T> T
unwrapLane(Class<T> laneClass)
void
warn(Object message)
Logs a warn-level message.abstract LaneView
willCommand(WillCommand willCommand)
abstract LaneView
willEnter(WillEnter willEnter)
abstract LaneView
willLeave(WillLeave willLeave)
abstract LaneView
willRequest(WillRequestHttp<?> willRequest)
abstract LaneView
willRespond(WillRespondHttp<?> willRespond)
abstract LaneView
willUplink(WillUplink willUplink)
-
Methods inherited from class swim.runtime.AbstractTierBinding
activate, didClose, didFail, didLoad, didOpen, didStart, didStop, didUnload, isClosed, isLoaded, isOpened, isStarted, load, open, start, stop, unload, willClose, willLoad, willOpen, willStart, willStop, willUnload
-
Methods inherited from class swim.runtime.AbstractSwimRef
command, command, command, command, command, command, command, command, downlink, downlinkHttp, downlinkList, downlinkMap, downlinkValue, downlinkWs, hostRef, hostRef, laneRef, laneRef, laneRef, laneRef, nodeRef, nodeRef, nodeRef, nodeRef
-
-
-
-
Field Detail
-
observers
protected volatile Object observers
-
-
Constructor Detail
-
LaneView
public LaneView(Object observers)
-
-
Method Detail
-
tierContext
public TierContext tierContext()
- Specified by:
tierContext
in interfaceTierBinding
- Specified by:
tierContext
in classAbstractTierBinding
-
agentContext
public abstract AgentContext agentContext()
-
laneBinding
public abstract LaneBinding laneBinding()
-
laneContext
public LaneContext laneContext()
-
createLaneBinding
public abstract LaneBinding createLaneBinding()
-
unwrapLane
public <T> T unwrapLane(Class<T> laneClass)
-
close
public abstract void close()
- Specified by:
close
in interfaceLane
- Specified by:
close
in interfaceSwimRef
- Specified by:
close
in interfaceTierBinding
- Overrides:
close
in classAbstractTierBinding
-
willCommand
public abstract LaneView willCommand(WillCommand willCommand)
- Specified by:
willCommand
in interfaceLane
-
didCommand
public abstract LaneView didCommand(DidCommand didCommand)
- Specified by:
didCommand
in interfaceLane
-
willUplink
public abstract LaneView willUplink(WillUplink willUplink)
- Specified by:
willUplink
in interfaceLane
-
decodeRequest
public abstract LaneView decodeRequest(DecodeRequestHttp<Object> decodeRequest)
- Specified by:
decodeRequest
in interfaceHttpLane<Object>
- Specified by:
decodeRequest
in interfaceLane
-
willRequest
public abstract LaneView willRequest(WillRequestHttp<?> willRequest)
- Specified by:
willRequest
in interfaceHttpLane<Object>
- Specified by:
willRequest
in interfaceLane
-
didRequest
public abstract LaneView didRequest(DidRequestHttp<Object> didRequest)
- Specified by:
didRequest
in interfaceHttpLane<Object>
- Specified by:
didRequest
in interfaceLane
-
doRespond
public abstract LaneView doRespond(DoRespondHttp<Object> doRespond)
-
willRespond
public abstract LaneView willRespond(WillRespondHttp<?> willRespond)
- Specified by:
willRespond
in interfaceHttpLane<Object>
- Specified by:
willRespond
in interfaceLane
-
didRespond
public abstract LaneView didRespond(DidRespondHttp<?> didRespond)
- Specified by:
didRespond
in interfaceHttpLane<Object>
- Specified by:
didRespond
in interfaceLane
-
dispatchWillCommand
protected boolean dispatchWillCommand(Value body, boolean preemptive)
-
dispatchDidCommand
protected boolean dispatchDidCommand(Value body, boolean preemptive)
-
dispatchWillUplink
protected boolean dispatchWillUplink(Uplink uplink, boolean preemptive)
-
dispatchDidUplink
protected boolean dispatchDidUplink(Uplink uplink, boolean preemptive)
-
dispatchWillEnter
protected boolean dispatchWillEnter(Identity identity, boolean preemptive)
-
dispatchDidEnter
protected boolean dispatchDidEnter(Identity identity, boolean preemptive)
-
dispatchWillLeave
protected boolean dispatchWillLeave(Identity identity, boolean preemptive)
-
dispatchDidLeave
protected boolean dispatchDidLeave(Identity identity, boolean preemptive)
-
dispatchDecodeRequest
protected Decoder<Object> dispatchDecodeRequest(HttpUplink uplink, HttpRequest<?> request)
-
dispatchWillRequest
protected boolean dispatchWillRequest(HttpUplink uplink, HttpRequest<?> request, boolean preemptive)
-
dispatchDidRequest
protected boolean dispatchDidRequest(HttpUplink uplink, HttpRequest<Object> request, boolean preemptive)
-
dispatchDoRespond
protected Object dispatchDoRespond(HttpUplink uplink, HttpRequest<Object> request, boolean preemptive)
-
dispatchWillRespond
protected boolean dispatchWillRespond(HttpUplink uplink, HttpResponse<?> response, boolean preemptive)
-
dispatchDidRespond
protected boolean dispatchDidRespond(HttpUplink uplink, HttpResponse<?> response, boolean preemptive)
-
laneWillCommand
public void laneWillCommand(CommandMessage message)
-
laneDidCommand
public void laneDidCommand(CommandMessage message)
-
laneWillUplink
public void laneWillUplink(Uplink uplink)
-
laneDidUplink
public void laneDidUplink(Uplink uplink)
-
laneWillEnter
public void laneWillEnter(Identity identity)
-
laneDidEnter
public void laneDidEnter(Identity identity)
-
laneWillLeave
public void laneWillLeave(Identity identity)
-
laneDidLeave
public void laneDidLeave(Identity identity)
-
laneDecodeRequest
public Decoder<Object> laneDecodeRequest(HttpUplink uplink, HttpRequest<?> request)
-
laneWillRequest
public void laneWillRequest(HttpUplink uplink, HttpRequest<?> request)
-
laneDidRequest
public void laneDidRequest(HttpUplink uplink, HttpRequest<Object> request)
-
laneDoRespond
public HttpResponse<?> laneDoRespond(HttpUplink uplink, HttpRequest<Object> request)
-
laneWillRespond
public void laneWillRespond(HttpUplink uplink, HttpResponse<?> response)
-
laneDidRespond
public void laneDidRespond(HttpUplink uplink, HttpResponse<?> response)
-
laneDidFail
public void laneDidFail(Throwable error)
-
meshUri
public Uri meshUri()
- Specified by:
meshUri
in interfaceCellContext
-
policy
public Policy policy()
- Specified by:
policy
in interfaceCellContext
-
schedule
public Schedule schedule()
- Specified by:
schedule
in interfaceCellContext
-
stage
public Stage stage()
- Specified by:
stage
in interfaceCellContext
-
store
public StoreBinding store()
- Specified by:
store
in interfaceCellContext
-
bindDownlink
public LinkBinding bindDownlink(Downlink downlink)
- Specified by:
bindDownlink
in interfaceCellContext
-
openDownlink
public void openDownlink(LinkBinding link)
- Specified by:
openDownlink
in interfaceCellContext
-
closeDownlink
public void closeDownlink(LinkBinding link)
- Specified by:
closeDownlink
in interfaceCellContext
-
httpDownlink
public void httpDownlink(HttpBinding http)
- Specified by:
httpDownlink
in interfaceCellContext
-
pushDown
public void pushDown(PushRequest pushRequest)
- Specified by:
pushDown
in interfaceCellContext
-
trace
public void trace(Object message)
Description copied from interface:Log
Logs a trace-level message.
-
debug
public void debug(Object message)
Description copied from interface:Log
Logs a debug-level message.
-
info
public void info(Object message)
Description copied from interface:Log
Logs an info-level message.
-
warn
public void warn(Object message)
Description copied from interface:Log
Logs a warn-level message.
-
-