public interface StreamSubscriptionTimeoutSupport
CancellingSubscriber
to the publisher, or by calling onError
on the timed-out subscriber.
See akka.stream.materializer.subscription-timeout
for configuration options.
Modifier and Type | Interface and Description |
---|---|
static class |
StreamSubscriptionTimeoutSupport.CancelingSubscriber$
A subscriber who calls
cancel directly from onSubscribe and ignores all other callbacks. |
static class |
StreamSubscriptionTimeoutSupport.NoopSubscriptionTimeout$
INTERNAL API
|
Modifier and Type | Method and 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) |
StreamSubscriptionTimeoutSettings subscriptionTimeoutSettings()
Cancellable scheduleSubscriptionTimeout(ActorRef actor, java.lang.Object message)
actor
- (undocumented)message
- (undocumented)void cancel(org.reactivestreams.Publisher<?> target, scala.concurrent.duration.FiniteDuration timeout)
void warn(org.reactivestreams.Publisher<?> target, scala.concurrent.duration.FiniteDuration timeout)
void subscriptionTimedOut(org.reactivestreams.Publisher<?> target)
Publisher
or Processor
target.target
- (undocumented)void handleSubscriptionTimeout(org.reactivestreams.Publisher<?> target, java.lang.Exception cause)
target
- (undocumented)cause
- (undocumented)