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
          pull(sslIn)
          pull(bytesIn)
        } else {
          failStage(new ProxyConnectionFailedException(s"The HTTPS proxy rejected to open a connection to $targetHostName:$targetPort"))
        }
      case Connected ⇒
        push(sslOut, grab(bytesIn))
    }
  }

setHandler(bytesOut, new OutHandler {
  override def onPull() = {
    state match {
      case Starting ⇒
        push(bytesOut, connectMsg)
        state = Connecting
      case Connecting ⇒
        // don't need to do anything
      case Connected ⇒
        pull(sslIn)
    }
  }
})