Parameters

null:Nullnull:Null

subClasses

superClasses

code.data.Exceptor

code.data.HasLogSource

code.data.PayloadCoercion

java.lang.Object

scala.lang.Any

Js Constructors

new code_data_StreamProcessor(
    incomingConfig, // code.data.O
    repo, // code.data.IFlowRepository
    typeTagA, // null:Null
    typeTagB // null:Null
)

ApplyMethods

Methods

$bang$eq(x$1:scala.lang.Any:Any, ):java.lang.Boolean:Boolean

$eq$eq(x$1:scala.lang.Any:Any, ):java.lang.Boolean:Boolean

$hash$hash():java.lang.Int:Int

$init$():scala.Unit:Unit

act(in:code.data.Payload[code.data.Datum], flowOrchestration:code.data.IFlowOrchestration, ):code.data.Payload[null:Null]

asInstanceOf():null:Null

config():code.data.O

configurationContext():scala.Option[code.data.ConfigurationContext]

configurationEquals(other:scala.lang.Any:Any, ):java.lang.Boolean:Boolean

connectorTestConfigUniqueness(unused:scala.lang.Any:Any, ):scala.Option[scala.lang.Any:Any]

connectorTestPayloadDefinition(unused:scala.lang.Any:Any, ):scala.Option[code.data.O]

createTestPayloadAroundItems(items:Unknown:Nothing, ):code.data.Payload[null:Null]

defaultPayload():code.data.Payload[null:Null]

delegateConnectorTestTo():scala.collection.immutable.List[code.data.StreamProcessor[code.data.Datumcode.data.Datum]]

eq(x$1:java.lang.Object:Object, ):java.lang.Boolean:Boolean

equals(x$1:scala.lang.Any:Any, ):java.lang.Boolean:Boolean

getClass():java.lang.Class[scala.lang.Any:Any]

getClassPath():java.lang.String:String

getConfiguration():code.data.O

getNextStepNameFunc(payload:scala.Option[code.data.Payload[code.data.Datum]], streamProcessors:scala.collection.immutable.Map[code.data.StreamProcessor[code.data.Datumcode.data.Datum]java.lang.String:String], ):scala.Option[scala.Function0[scala.Option[java.lang.String:String]]]

hashCode():java.lang.Int:Int

inType():code.data.documentation.Doc

isConnector():java.lang.Boolean:Boolean

isInstanceOf():java.lang.Boolean:Boolean

localShutdown(repo:code.data.IFlowRepository, lock:code.data.FlowLock, ):scala.Unit:Unit

localStartup(repo:code.data.IFlowRepository, lock:code.data.FlowLock, ):scala.Unit:Unit

logSource():scala.Some[code.data.LogSource]

name():java.lang.String:String

ne(x$1:java.lang.Object:Object, ):java.lang.Boolean:Boolean

newFromConfig():scala.util.Either[code.data.StreamProcessor[code.data.Datumcode.data.Datum]java.lang.Exception]

notify():scala.Unit:Unit

notifyAll():scala.Unit:Unit

outType():code.data.documentation.Doc

parseConnectorTestPayload(in:code.data.O, ):scala.Option[scala.Tuple2[code.data.Payload[null:Null]scala.Option[code.data.O]]]

repo():code.data.IFlowRepository

responseVerifier():scala.Option[java.lang.String:String]

shouldPin():scala.collection.immutable.List[java.lang.String:String]

synchronized(x$1:null:Null, ):null:Null

testData():scala.Option[net.liftweb.json.JsonAST$JValue]

toString():java.lang.String:String

transformTestDataFunc():scala.Option[java.lang.String:String]

typeTagA():null:Null

typeTagB():null:Null

wait():scala.Unit:Unit

wait(x$1:java.lang.Long:Long, ):scala.Unit:Unit

wait(x$1:java.lang.Long:Long, x$2:java.lang.Int:Int, ):scala.Unit:Unit