raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

!str #16263 Made subscription timeout handling run mostly inside the actor

Browse source
This commit is contained in:
Björn Antonsson 2014-11-12 13:05:57 +01:00
parent d60d5bc849
commit 5a26718050
5 changed files with 134 additions and 140 deletions
Download patch file Download diff file Expand all files Collapse all files

15
akka-stream/src/main/scala/akka/stream/FlowMaterializer.scala
View file

@ -250,6 +250,7 @@ final case class MaterializerSettings(
}
object StreamSubscriptionTimeoutSettings {
import StreamSubscriptionTimeoutTerminationMode._
/** Java API */
def create(config: Config): StreamSubscriptionTimeoutSettings =
@ -263,21 +264,23 @@ object StreamSubscriptionTimeoutSettings {
case "warn" ⇒ WarnTermination
case "cancel" ⇒ CancelTermination
},
timeout = c.getDuration("timeout", TimeUnit.MILLISECONDS).millis,
dispatcher = c.getString("dispatcher"))
timeout = c.getDuration("timeout", TimeUnit.MILLISECONDS).millis)
}
}
final case class StreamSubscriptionTimeoutSettings(mode: StreamSubscriptionTimeoutTerminationMode, timeout: FiniteDuration, dispatcher: String)
final case class StreamSubscriptionTimeoutSettings(mode: StreamSubscriptionTimeoutTerminationMode, timeout: FiniteDuration)
sealed abstract class StreamSubscriptionTimeoutTerminationMode
object StreamSubscriptionTimeoutTerminationMode {
case object NoopTermination extends StreamSubscriptionTimeoutTerminationMode
case object WarnTermination extends StreamSubscriptionTimeoutTerminationMode
case object CancelTermination extends StreamSubscriptionTimeoutTerminationMode
/** Java API */
def noop = NoopTermination
/** Java API */
def warn = WarnTermination
/** Java API */
def cancel = CancelTermination
}
case object NoopTermination extends StreamSubscriptionTimeoutTerminationMode
case object WarnTermination extends StreamSubscriptionTimeoutTerminationMode
case object CancelTermination extends StreamSubscriptionTimeoutTerminationMode