Class Inlet<T>

java.lang.Object
org.apache.pekko.stream.InPort
org.apache.pekko.stream.Inlet<T>

public final class Inlet<T> extends InPort
  • Constructor Details

    • Inlet

      public Inlet()
  • Method Details

    • apply

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

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

    • create

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

      Creates a new Inlet 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 Inlet<T> carbonCopy()
    • as

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

      public String toString()
      Overrides:
      toString in class Object