diff --git a/lib/thrift/binary/framed/protocol_handler.ex b/lib/thrift/binary/framed/protocol_handler.ex index 409ff5cc..240c1144 100644 --- a/lib/thrift/binary/framed/protocol_handler.ex +++ b/lib/thrift/binary/framed/protocol_handler.ex @@ -90,6 +90,7 @@ defmodule Thrift.Binary.Framed.ProtocolHandler do else {:error, {:server_error, thrift_data}} -> :ok = transport.send(socket, thrift_data) + :ok = transport.close(socket) exit({:shutdown, :server_error}) {:error, {:protocol_error, reason}} ->