MOAR!

Author: keelerm84

eventsource-client/src/client.rs

@@ -492,20 +492,24 @@ where
                 },
                 StateProj::FollowingRedirect(maybe_header) => match uri_from_header(maybe_header) {
                     Ok(uri) => {
+                        trace!("FollowingRedirect {:?}", uri);
                         *self.as_mut().project().current_url = uri;
                         self.as_mut().project().state.set(State::New);
                     }
                     Err(e) => {
+                        trace!("FollowingRedirect error {:?}", e);
                         self.as_mut().project().state.set(State::StreamClosed);
                         return Poll::Ready(Some(Err(e)));
                     }
                 },
                 StateProj::Connected(body) => match ready!(body.poll_data(cx)) {
                     Some(Ok(result)) => {
+                        trace!("Connected with result {:?}", result);
                         this.event_parser.process_bytes(result)?;
                         continue;
                     }
                     Some(Err(e)) => {
+                        trace!("Connected with error {:?}", e);
                         if self.props.reconnect_opts.reconnect {
                             let duration = self.as_mut().backoff();
                             self.as_mut()
@@ -517,6 +521,7 @@ where
                         if let Some(cause) = e.source() {
                             if let Some(downcast) = cause.downcast_ref::<std::io::Error>() {
                                 if let std::io::ErrorKind::TimedOut = downcast.kind() {
+                                    trace!("Timeout");
                                     return Poll::Ready(Some(Err(Error::TimedOut)));
                                 }
                             }
@@ -525,19 +530,23 @@ where
                         }
                     }
                     None => {
+                        trace!("Connected with None");
                         let duration = self.as_mut().backoff();
                         self.as_mut()
                             .project()
                             .state
                             .set(State::WaitingToReconnect(delay(duration, "retrying")));
 
                         if self.event_parser.was_processing() {
+                            trace!("UnexpectedEof");
                             return Poll::Ready(Some(Err(Error::UnexpectedEof)));
                         }
+                        trace!("Eof");
                         return Poll::Ready(Some(Err(Error::Eof)));
                     }
                 },
                 StateProj::WaitingToReconnect(delay) => {
+                    trace!("WaitingToReconnect {:?}", delay);
                     ready!(delay.poll(cx));
                     info!("Reconnecting");
                     self.as_mut().project().state.set(State::New);