Class SinkModule<In,​Mat>

    • Constructor Detail

      • SinkModule

        public SinkModule​(SinkShape<In> shape)
    • Method Detail

      • attributes

        public abstract Attributes attributes()
      • create

        public abstract scala.Tuple2<java.lang.Object,​Mat> create​(MaterializationContext context)
        Create the Subscriber or VirtualPublisher that consumes the incoming stream, plus the materialized value. Since Subscriber and VirtualPublisher do not share a common supertype apart from AnyRef this is what the type union devolves into; unfortunately we do not have union types at our disposal at this point.
      • label

        protected java.lang.String label()
      • shape

        public SinkShape<In> shape()
        Description copied from interface: Graph
        The shape of a graph is all that is externally visible: its inlets and outlets.
        Specified by:
        shape in interface Graph<In,​Mat>
      • toString

        public final java.lang.String toString()
        Overrides:
        toString in class java.lang.Object
      • traversalBuilder

        public TraversalBuilder traversalBuilder()
        Description copied from interface: Graph
        INTERNAL API.

        Every materializable element must be backed by a stream layout module

        Specified by:
        traversalBuilder in interface Graph<In,​Mat>