public class AeronSource extends GraphStageWithMaterializedValue<SourceShape<EnvelopeBuffer>,AeronSource.ResourceLifecycle>
Modifier and Type | Class and Description |
---|---|
static class |
AeronSource.Fragments |
static class |
AeronSource.MessageHandler |
static interface |
AeronSource.ResourceLifecycle |
Constructor and Description |
---|
AeronSource(java.lang.String channel,
int streamId,
io.aeron.Aeron aeron,
TaskRunner taskRunner,
EnvelopeBufferPool pool,
EventSink flightRecorder,
int spinning) |
Modifier and Type | Method and Description |
---|---|
static Graph<S,M> |
addAttributes(Attributes attr) |
static Graph<S,M> |
async() |
scala.Tuple2<GraphStageLogic,GraphStageLogic> |
createLogicAndMaterializedValue(Attributes inheritedAttributes) |
protected static Attributes |
initialAttributes() |
static StreamLayout.Module |
module() |
static Graph<S,M> |
named(java.lang.String name) |
Outlet<EnvelopeBuffer> |
out() |
SourceShape<EnvelopeBuffer> |
shape()
The shape of a graph is all that is externally visible: its inlets and outlets.
|
static Graph<S,M> |
withAttributes(Attributes attr) |
initialAttributes, module, withAttributes
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addAttributes, async, named
public AeronSource(java.lang.String channel, int streamId, io.aeron.Aeron aeron, TaskRunner taskRunner, EnvelopeBufferPool pool, EventSink flightRecorder, int spinning)
public static Graph<S,M> named(java.lang.String name)
public static Graph<S,M> async()
public static Graph<S,M> addAttributes(Attributes attr)
protected static Attributes initialAttributes()
public static final StreamLayout.Module module()
public static final Graph<S,M> withAttributes(Attributes attr)
public Outlet<EnvelopeBuffer> out()
public SourceShape<EnvelopeBuffer> shape()
Graph
public scala.Tuple2<GraphStageLogic,GraphStageLogic> createLogicAndMaterializedValue(Attributes inheritedAttributes)