the description for this gist

post.scala

setHandler(bytesIn, new InHandler {
  override def onPush() = {
    state match {
      case Starting ⇒
      // that means that proxy had sent us something even before CONNECT to proxy was sent, therefore we just ignore it
      case Connecting ⇒
        val proxyResponse = grab(bytesIn)
        if(proxyResponseValid(proxyResponse)) {
          state = Connected
          emitMultiple(bytesOut, bufferedMsgs)
        } else {
          failStage(new ProxyConnectionFailedException(s"The HTTPS proxy rejected to open a connection to $targetHostName:$targetPort"))
        }
      case Connected ⇒
        push(sslOut, grab(bytesIn))
    }
  }
})