the description for this gist

post.scala

// before:
    ...
    (subscriber, AssignableCancelable.dummy)
    // after:
    ...
    val cancelable = AssignableCancelable.single()
    ch.addShutdownListener(_ => cancelable.cancel())
    (subscriber, cancelable)
  }