Package akka.stream

Interface Graph<S extends Shape,​M>

    • Method Detail

      • shape

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

        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.