public class AeronSink extends GraphStageWithMaterializedValue<SinkShape<EnvelopeBuffer>,scala.concurrent.Future<Done>>
Modifier and Type | Class and Description |
---|---|
static class |
AeronSink.GaveUpMessageException |
static class |
AeronSink.PublicationClosedException |
Constructor and Description |
---|
AeronSink(java.lang.String channel,
int streamId,
io.aeron.Aeron aeron,
TaskRunner taskRunner,
EnvelopeBufferPool pool,
scala.concurrent.duration.Duration giveUpAfter,
EventSink flightRecorder) |
Modifier and Type | Method and Description |
---|---|
static Graph<S,M> |
addAttributes(Attributes attr) |
static Graph<S,M> |
async() |
scala.Tuple2<GraphStageLogic,scala.concurrent.Future<Done>> |
createLogicAndMaterializedValue(Attributes inheritedAttributes) |
Inlet<EnvelopeBuffer> |
in() |
protected static Attributes |
initialAttributes() |
static StreamLayout.Module |
module() |
static Graph<S,M> |
named(java.lang.String name) |
SinkShape<EnvelopeBuffer> |
shape()
The shape of a graph is all that is externally visible: its inlets and outlets.
|
static int |
TimerCheckMask() |
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 AeronSink(java.lang.String channel, int streamId, io.aeron.Aeron aeron, TaskRunner taskRunner, EnvelopeBufferPool pool, scala.concurrent.duration.Duration giveUpAfter, EventSink flightRecorder)
public static int TimerCheckMask()
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 Inlet<EnvelopeBuffer> in()
public SinkShape<EnvelopeBuffer> shape()
Graph
public scala.Tuple2<GraphStageLogic,scala.concurrent.Future<Done>> createLogicAndMaterializedValue(Attributes inheritedAttributes)
createLogicAndMaterializedValue
in class GraphStageWithMaterializedValue<SinkShape<EnvelopeBuffer>,scala.concurrent.Future<Done>>