java.lang.IllegalStateException: The first message must be `ExposedPublisher` but was [FromConnection(OnComplete)]

GitHub | drewhk | 4 months ago
  1. 0

    BUG: PoolSlot actor does not get ExposedPublisher as first message sometimes

    GitHub | 4 months ago | drewhk
    java.lang.IllegalStateException: The first message must be `ExposedPublisher` but was [FromConnection(OnComplete)]
  2. 0

    GitHub comment 20570#221429671

    GitHub | 6 months ago | cppexpert
    java.lang.IllegalStateException: The first message must be `ExposedPublisher` but was [FromConnection(OnComplete)]
  3. 0

    Akka-http Cached connection pool throws exception when tcp connection is closed right after receiving the response

    GitHub | 10 months ago | remcobeckers
    java.lang.IllegalStateException: The first message must be `ExposedPublisher` but was [OnComplete]
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    GitHub comment 19643#177852646

    GitHub | 10 months ago | remcobeckers
    java.lang.IllegalStateException: The first message must be `ExposedPublisher` but was [Request(1)]
  6. 0

    Race during processor setup leads to exceptions (`ExposedPublisher` vs. `RequestMore`)

    GitHub | 3 years ago | jrudolph
    java.lang.IllegalStateException: The first message must be ExposedPublisher but was [RequestMore(akka.stream.impl.ActorSubscription@2c84d9d,4)]

    Not finding the right solution?
    Take a tour to get the most out of Samebug.

    Tired of useless tips?

    Automated exception search integrated into your IDE

    Root Cause Analysis

    1. java.lang.IllegalStateException

      The first message must be `ExposedPublisher` but was [FromConnection(OnComplete)]

      at akka.http.impl.engine.client.PoolSlot$SlotProcessor$$anonfun$waitingExposedPublisher$1.applyOrElse()
    2. akka.http.impl
      PoolSlot$SlotProcessor$$anonfun$waitingExposedPublisher$1.applyOrElse
      1. akka.http.impl.engine.client.PoolSlot$SlotProcessor$$anonfun$waitingExposedPublisher$1.applyOrElse(PoolSlot.scala:120)
      1 frame
    3. Akka Actor
      Actor$class.aroundReceive
      1. akka.actor.Actor$class.aroundReceive(Actor.scala:484)
      1 frame
    4. akka.http.impl
      PoolSlot$SlotProcessor.akka$stream$actor$ActorSubscriber$$super$aroundReceive
      1. akka.http.impl.engine.client.PoolSlot$SlotProcessor.akka$stream$actor$ActorSubscriber$$super$aroundReceive(PoolSlot.scala:92)
      1 frame
    5. akka.stream.actor
      ActorSubscriber$class.aroundReceive
      1. akka.stream.actor.ActorSubscriber$class.aroundReceive(ActorSubscriber.scala:201)
      1 frame
    6. akka.http.impl
      PoolSlot$SlotProcessor.akka$stream$actor$ActorPublisher$$super$aroundReceive
      1. akka.http.impl.engine.client.PoolSlot$SlotProcessor.akka$stream$actor$ActorPublisher$$super$aroundReceive(PoolSlot.scala:92)
      1 frame