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

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 actual Publisher or Processor 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)