reconnected.next() = None, action = Pending => {
  cancel action;
  return Error(Subscription_droppped)
}
reconnected.next() = Some(true), action = Pending => {
  // Subscription received FollowEvent::Initialized
  loop again to retry the action
}
reconnected.next() = Some(false), action = Pending => {
  // Subscription received FollowEvent::Stop
  loop { 
    reconnected.next() until it returns Some(true)
  }  
  loop again to retry the action
}
reconnected.next() = Pending, action = Ready(result) => {
  try polling the pending `reconnected.next()` and if it is None {
   return result from the action
  } else {
    loop { 
       reconnected.next() until it returns Some(true)
    }
    loop again to retry the action
  }
}