public abstract class MaterializerSession
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
MaterializerSession.MaterializationPanic |
Constructor and Description |
---|
MaterializerSession(StreamLayout.Module topLevel,
Attributes initialAttributes) |
Modifier and Type | Method and Description |
---|---|
protected void |
assignPort(InPort in,
java.lang.Object subscriberOrVirtual) |
protected void |
assignPort(OutPort out,
org.reactivestreams.Publisher<java.lang.Object> publisher) |
static boolean |
Debug() |
protected void |
enterScope(StreamLayout.CopiedModule enclosing) |
protected void |
exitScope(StreamLayout.CopiedModule enclosing) |
Attributes |
initialAttributes() |
java.lang.Object |
materialize() |
protected abstract void |
materializeAtomic(StreamLayout.AtomicModule atomic,
Attributes effectiveAttributes,
java.util.Map<StreamLayout.Module,java.lang.Object> matVal) |
protected java.lang.Object |
materializeComposite(StreamLayout.Module composite,
Attributes effectiveAttributes) |
protected java.lang.Object |
materializeModule(StreamLayout.Module module,
Attributes effectiveAttributes) |
protected Attributes |
mergeAttributes(Attributes parent,
Attributes current) |
void |
registerSrc(GraphStages.MaterializedValueSource<java.lang.Object> ms) |
StreamLayout.Module |
topLevel() |
public MaterializerSession(StreamLayout.Module topLevel, Attributes initialAttributes)
public static final boolean Debug()
public StreamLayout.Module topLevel()
public Attributes initialAttributes()
protected void enterScope(StreamLayout.CopiedModule enclosing)
protected void exitScope(StreamLayout.CopiedModule enclosing)
public final java.lang.Object materialize()
protected Attributes mergeAttributes(Attributes parent, Attributes current)
public void registerSrc(GraphStages.MaterializedValueSource<java.lang.Object> ms)
protected java.lang.Object materializeModule(StreamLayout.Module module, Attributes effectiveAttributes)
protected java.lang.Object materializeComposite(StreamLayout.Module composite, Attributes effectiveAttributes)
protected abstract void materializeAtomic(StreamLayout.AtomicModule atomic, Attributes effectiveAttributes, java.util.Map<StreamLayout.Module,java.lang.Object> matVal)
protected void assignPort(InPort in, java.lang.Object subscriberOrVirtual)
protected void assignPort(OutPort out, org.reactivestreams.Publisher<java.lang.Object> publisher)