Test socket closed by remote

plain.sh

while true; do printf 'HTTP/1.1 200 OK\r\nServer: test\r\n'|nc -l 3000; done

TestClose.scala

import com.twitter.finagle.Http
import com.twitter.finagle.http.{Http => _, _}
import com.twitter.io.{Buf, Reader}
import com.twitter.util.Await

val tls = Http.client.withStreaming(enabled=true).withTlsWithoutValidation.newService("localhost:4433")
val plain = Http.client.withStreaming(enabled=true).newService("localhost:3000")

val tlsReq = Request(Version.Http11, Method.Get, "/", Reader.writable())
val tlsRes = Await.result(tls(tlsReq).liftToTry)
println("TLS response failed? " + tlsRes.isThrow)

val plainReq = Request(Version.Http11, Method.Get, "/", Reader.writable())
val plainRes = Await.result(plain(plainReq).liftToTry)
println("TLS response failed? " + plainRes.isThrow)

tls.sh

while true; do printf 'HTTP/1.1 200 OK\r\nServer: test\r\n'|openssl s_server; done