From 9235e12904eda411ffc39d9ed6d7d4d92afbe1b3 Mon Sep 17 00:00:00 2001
From: Tim Kuehn <tikue@google.com>
Date: Sat, 2 Apr 2016 15:33:56 -0700
Subject: [PATCH] Handle Serde(EndOfStream) error as ConnectionBroken

---
 tarpc/src/protocol/mod.rs | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/tarpc/src/protocol/mod.rs b/tarpc/src/protocol/mod.rs
index 31dc43e..c7e2132 100644
--- a/tarpc/src/protocol/mod.rs
+++ b/tarpc/src/protocol/mod.rs
@@ -6,6 +6,7 @@
 use bincode::{self, SizeLimit};
 use bincode::serde::{deserialize_from, serialize_into};
 use serde;
+use serde::de::value::Error::EndOfStream;
 use std::io::{self, Read, Write};
 use std::convert;
 use std::sync::Arc;
@@ -40,6 +41,7 @@ impl convert::From<bincode::serde::SerializeError> for Error {
 impl convert::From<bincode::serde::DeserializeError> for Error {
     fn from(err: bincode::serde::DeserializeError) -> Error {
         match err {
+            bincode::serde::DeserializeError::Serde(EndOfStream) => Error::ConnectionBroken,
             bincode::serde::DeserializeError::IoError(err) => {
                 match err.kind() {
                     io::ErrorKind::ConnectionReset |