split Reconnect events into Disconnect/Connect

this makes the logic easier to follow, and also opens up the possibility
of doing something different during times that we are actively
disconnected

1 files changed, 4 insertions, 1 deletions

diff --git a/src/cmd/stream.rs b/src/cmd/stream.rs
index dc0e18d..28fd6b1 100644
--- a/src/cmd/stream.rs
+++ b/src/cmd/stream.rs
@@ -191,7 +191,10 @@ impl StreamSession {
     ) -> Result<crate::component_future::Poll<()>> {
         match self.client.poll().context(Client) {
             Ok(futures::Async::Ready(Some(e))) => match e {
-                crate::client::Event::Reconnect(size) => {
+                crate::client::Event::Disconnect => {
+                    Ok(crate::component_future::Poll::DidWork)
+                }
+                crate::client::Event::Connect(size) => {
                     self.sent_remote = 0;
                     self.process.resize(size);
                     Ok(crate::component_future::Poll::DidWork)