Package akka.remote.artery.aeron
Class AeronSource
- java.lang.Object
-
- akka.stream.stage.GraphStageWithMaterializedValue<SourceShape<EnvelopeBuffer>,AeronSource.AeronLifecycle>
-
- akka.remote.artery.aeron.AeronSource
-
- All Implemented Interfaces:
Graph<SourceShape<EnvelopeBuffer>,AeronSource.AeronLifecycle>
public class AeronSource extends GraphStageWithMaterializedValue<SourceShape<EnvelopeBuffer>,AeronSource.AeronLifecycle>
INTERNAL API param: channel eg. "aeron:udp?endpoint=localhost:40123" param: spinning the amount of busy spinning to be done synchronously before deferring to the TaskRunner when waiting for data
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static interface
AeronSource.AeronLifecycle
static class
AeronSource.Fragments
static class
AeronSource.MessageHandler
-
Constructor Summary
Constructors Constructor Description AeronSource(java.lang.String channel, int streamId, io.aeron.Aeron aeron, TaskRunner taskRunner, EnvelopeBufferPool pool, EventSink flightRecorder, int spinning)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description scala.Tuple2<GraphStageLogic,GraphStageLogic>
createLogicAndMaterializedValue(Attributes inheritedAttributes)
Outlet<EnvelopeBuffer>
out()
SourceShape<EnvelopeBuffer>
shape()
The shape of a graph is all that is externally visible: its inlets and outlets.-
Methods inherited from class akka.stream.stage.GraphStageWithMaterializedValue
createLogicAndMaterializedValue, initialAttributes, traversalBuilder, withAttributes
-
-
-
-
Constructor Detail
-
AeronSource
public AeronSource(java.lang.String channel, int streamId, io.aeron.Aeron aeron, TaskRunner taskRunner, EnvelopeBufferPool pool, EventSink flightRecorder, int spinning)
-
-
Method Detail
-
out
public Outlet<EnvelopeBuffer> out()
-
shape
public SourceShape<EnvelopeBuffer> shape()
Description copied from interface:Graph
The shape of a graph is all that is externally visible: its inlets and outlets.- Returns:
- (undocumented)
-
createLogicAndMaterializedValue
public scala.Tuple2<GraphStageLogic,GraphStageLogic> createLogicAndMaterializedValue(Attributes inheritedAttributes)
-
-