Skip to content

Instantly share code, notes, and snippets.

@joost-de-vries
Created January 19, 2017 09:11
Show Gist options
  • Select an option

  • Save joost-de-vries/a4cfa5d89e950d250c4857e0f4eaf2be to your computer and use it in GitHub Desktop.

Select an option

Save joost-de-vries/a4cfa5d89e950d250c4857e0f4eaf2be to your computer and use it in GitHub Desktop.
Caused by: swave.core.UnclosedStreamGraphException: Unconnected Port in MapStage@15faa2dd/awaitingOnSubscribe
at swave.core.impl.stages.StageImpl._xSeal(StageImpl.scala:313)
at swave.core.impl.stages.inout.MapStage._xSeal(MapStage.scala:16)
at swave.core.impl.stages.StageImpl.xSeal(StageImpl.scala:291)
at swave.core.impl.stages.inout.NopStage._xSeal(NopStage.scala:15)
at swave.core.impl.stages.StageImpl.xSeal(StageImpl.scala:291)
at swave.core.impl.stages.inout.MapStage._xSeal(MapStage.scala:16)
at swave.core.impl.stages.StageImpl.xSeal(StageImpl.scala:291)
at swave.core.impl.stages.drain.PublisherDrainStage._xSeal(PublisherDrainStage.scala:20)
at swave.core.impl.stages.StageImpl.xSeal(StageImpl.scala:291)
at swave.core.impl.stages.StageImpl.sealBoundaries$1(StageImpl.scala:298)
Caused by: java.lang.IllegalStateException: Unexpected xSeal() in MapStage@15faa2dd/awaitingOnSubscribe
at swave.core.impl.stages.StageImpl.illegalState(StageImpl.scala:86)
at swave.core.impl.stages.StageImpl._xSeal(StageImpl.scala:313)
at swave.core.impl.stages.inout.MapStage._xSeal(MapStage.scala:16)
at swave.core.impl.stages.StageImpl.xSeal(StageImpl.scala:291)
at swave.core.impl.stages.inout.NopStage._xSeal(NopStage.scala:15)
at swave.core.impl.stages.StageImpl.xSeal(StageImpl.scala:291)
at swave.core.impl.stages.inout.MapStage._xSeal(MapStage.scala:16)
at swave.core.impl.stages.StageImpl.xSeal(StageImpl.scala:291)
at swave.core.impl.stages.drain.PublisherDrainStage._xSeal(PublisherDrainStage.scala:20)
at swave.core.impl.stages.StageImpl.xSeal(StageImpl.scala:291)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment