Interface StreamSubscriptionTimeoutSupport

  • public interface StreamSubscriptionTimeoutSupport
    Default settings for subscription timeouts.
    • Method Detail

      • 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.
        actor - (undocumented)
        message - (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.
        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.
        target - (undocumented)
        cause - (undocumented)