Class Outlet<T>

java.lang.Object
org.apache.pekko.stream.OutPort
org.apache.pekko.stream.Outlet<T>

public final class Outlet<T> extends OutPort
  • Constructor Details

    • Outlet

      public Outlet()
  • Method Details

    • apply

      public static <T> Outlet<T> apply(String name)
      Scala API

      Creates a new Outlet with the given name. The name will be used when displaying debug information or error messages involving the port.

    • create

      public static <T> Outlet<T> create(String name)
      JAVA API

      Creates a new Outlet with the given name. The name will be used when displaying debug information or error messages involving the port.

    • s

      public String s()
    • carbonCopy

      public Outlet<T> carbonCopy()
    • as

      public <U> Outlet<U> as()
      INTERNAL API.
    • toString

      public String toString()
      Overrides:
      toString in class Object