public class CallableWorkerResponseContext extends BaseWorkerResponseContext
Modifier and Type | Field and Description |
---|---|
protected boolean |
fulfilled |
protected int |
haltCount |
protected BType[] |
responseTypes |
protected Map<String,BMap<String,BValue>> |
workerErrors |
currentSignal, responseCallbacks, retRegIndexes, targetCtx, workerCount, workerDataChannels
Constructor and Description |
---|
CallableWorkerResponseContext(BType[] responseTypes,
int workerCount) |
doFailCallbackNotify, doSuccessCallbackNotify, getWorkerDataChannel, joinTargetContextInfo, modifyDebugCommands, onTimeout, registerResponseCallback, signal
protected BType[] responseTypes
protected boolean fulfilled
protected int haltCount
public CallableWorkerResponseContext(BType[] responseTypes, int workerCount)
protected boolean isFulfilled()
protected void setAsFulfilled()
protected void setCurrentSignal(WorkerSignal signal)
protected WorkerSignal getCurrentSignal()
protected void onMessage(WorkerSignal signal)
onMessage
in class BaseWorkerResponseContext
protected void handleAlreadyFulfilled(WorkerSignal signal)
protected WorkerExecutionContext propagateErrorToTarget()
protected WorkerExecutionContext onHalt(WorkerSignal signal)
onHalt
in class BaseWorkerResponseContext
protected boolean isReturnable()
protected void initWorkerErrors()
protected void printError(BMap<?,?> error)
protected boolean isWorkersDone()
protected void storeError(WorkerExecutionContext sourceCtx, BMap<String,BValue> error)
protected WorkerExecutionContext onError(WorkerSignal signal)
onError
in class BaseWorkerResponseContext
protected WorkerExecutionContext onFinalizedError(WorkerExecutionContext targetCtx, BMap<String,BValue> error)
protected void printStoredErrors()
protected WorkerExecutionContext onReturn(WorkerSignal signal)
onReturn
in class BaseWorkerResponseContext
public WorkerExecutionContext onFulfillment(boolean runInCaller)
Copyright © 2018 WSO2. All rights reserved.