eth-wire: catch rpc EOF

1 files changed, 5 insertions, 1 deletions

diff --git a/eth-wire/src/rpc.rs b/eth-wire/src/rpc.rs
index 4dadd8b..9ac6bea 100644
--- a/eth-wire/src/rpc.rs
+++ b/eth-wire/src/rpc.rs
@@ -147,6 +147,10 @@ impl Rpc {
                 self.read_buf.resize(self.cursor * 2, 0);
             }
             match self.conn.get_mut().read(&mut self.read_buf[self.cursor..]) {
+                Ok(0) => Err(std::io::Error::new(
+                    ErrorKind::UnexpectedEof,
+                    "RPC EOF".to_string(),
+                ))?,
                 Ok(nb) => {
                     self.cursor += nb;
                     let mut de: serde_json::StreamDeserializer<_, T> =
@@ -251,7 +255,7 @@ impl Rpc {
     }
 
     pub fn miner_start(&mut self) -> Result<()> {
-        match self.call("miner_start", &[1]) {
+        match self.call("miner_start", &[8]) {
             Err(Error::Null) => Ok(()),
             i => i,
         }