Package akka.stream

Interface Graph<S extends Shape,​M>

    • Nested Class Summary

      Nested Classes 
      Modifier and Type Interface Description
      static class  Graph.GraphMapMatVal<S extends Shape,​M>
      Scala API, see https://github.com/akka/akka/issues/28501 for discussion why this can't be an instance method on class Graph.
    • Method Detail

      • shape

        S shape()
        The shape of a graph is all that is externally visible: its inlets and outlets.
      • traversalBuilder

        akka.stream.impl.TraversalBuilder traversalBuilder()
        INTERNAL API.

        Every materializable element must be backed by a stream layout module

      • named

        Graph<S,​M> named​(java.lang.String name)
      • async

        Graph<S,​M> async()
        Put an asynchronous boundary around this Graph
      • async

        Graph<S,​M> async​(java.lang.String dispatcher)
        Put an asynchronous boundary around this Graph

        Parameters:
        dispatcher - Run the graph on this dispatcher
      • async

        Graph<S,​M> async​(java.lang.String dispatcher,
                               int inputBufferSize)
        Put an asynchronous boundary around this Graph

        Parameters:
        dispatcher - Run the graph on this dispatcher
        inputBufferSize - Set the input buffer to this size for the graph
      • addAttributes

        Graph<S,​M> addAttributes​(Attributes attr)
        Add the given attributes to this Graph. If the specific attribute was already present on this graph this means the added attribute will be more specific than the existing one. If this Source is a composite of multiple graphs, new attributes on the composite will be less specific than attributes set directly on the individual graphs of the composite.