Package akka.stream

Class StreamSubscriptionTimeoutSettings


  • public final class StreamSubscriptionTimeoutSettings
    extends java.lang.Object
    Leaked publishers and subscribers are cleaned up when they are not used within a given deadline, configured by StreamSubscriptionTimeoutSettings.
    • Method Detail

      • create

        public static StreamSubscriptionTimeoutSettings create​(com.typesafe.config.Config config)
        Create settings from a Config subsection (Java).
        Parameters:
        config - (undocumented)
        Returns:
        (undocumented)
      • apply

        public static StreamSubscriptionTimeoutSettings apply​(com.typesafe.config.Config config)
        Create settings from a Config subsection (Scala).
        Parameters:
        config - (undocumented)
        Returns:
        (undocumented)
      • timeout

        public scala.concurrent.duration.FiniteDuration timeout()
      • equals

        public boolean equals​(java.lang.Object other)
        Overrides:
        equals in class java.lang.Object
      • toString

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