Package akka.stream.impl
Interface StreamSubscriptionTimeoutSupport
-
public interface StreamSubscriptionTimeoutSupport
Default settings for subscription timeouts.
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static class
StreamSubscriptionTimeoutSupport.CancelingSubscriber$
static class
StreamSubscriptionTimeoutSupport.NoopSubscriptionTimeout$
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
cancel(org.reactivestreams.Publisher<?> target, scala.concurrent.duration.FiniteDuration timeout)
void
handleSubscriptionTimeout(org.reactivestreams.Publisher<?> target, java.lang.Exception cause)
Callback that should ensure that the target is canceled with the given cause.Cancellable
scheduleSubscriptionTimeout(ActorRef actor, java.lang.Object message)
Schedules a Subscription timeout.void
subscriptionTimedOut(org.reactivestreams.Publisher<?> target)
Called by the actor when a subscription has timed out.StreamSubscriptionTimeoutSettings
subscriptionTimeoutSettings()
Default settings for subscription timeouts.void
warn(org.reactivestreams.Publisher<?> target, scala.concurrent.duration.FiniteDuration timeout)
-
-
-
Method Detail
-
subscriptionTimeoutSettings
StreamSubscriptionTimeoutSettings subscriptionTimeoutSettings()
Default settings for subscription timeouts.- Returns:
- (undocumented)
-
scheduleSubscriptionTimeout
Cancellable scheduleSubscriptionTimeout(ActorRef actor, java.lang.Object message)
Schedules a Subscription timeout. The actor will receive the message created by the provided block if the timeout triggers.- Parameters:
actor
- (undocumented)message
- (undocumented)- Returns:
- (undocumented)
-
cancel
void cancel(org.reactivestreams.Publisher<?> target, scala.concurrent.duration.FiniteDuration timeout)
-
warn
void warn(org.reactivestreams.Publisher<?> target, scala.concurrent.duration.FiniteDuration timeout)
-
subscriptionTimedOut
void subscriptionTimedOut(org.reactivestreams.Publisher<?> target)
Called by the actor when a subscription has timed out. Expects the actualPublisher
orProcessor
target.- Parameters:
target
- (undocumented)
-
handleSubscriptionTimeout
void handleSubscriptionTimeout(org.reactivestreams.Publisher<?> target, java.lang.Exception cause)
Callback that should ensure that the target is canceled with the given cause.- Parameters:
target
- (undocumented)cause
- (undocumented)
-
-