Add cache test

Signed-off-by: Danil-Grigorev <[email protected]>

Author: Danil-Grigorev

kube-runtime/src/reflector/dispatcher.rs

@@ -152,6 +152,7 @@ where
 #[cfg(test)]
 pub(crate) mod test {
     use crate::{
+        reflector::ObjectRef,
         watcher::{Error, Event},
         WatchStreamExt,
     };
@@ -239,7 +240,7 @@ pub(crate) mod test {
         let foo = Arc::new(foo);
         let _bar = Arc::new(bar);
 
-        let (_, writer) = reflector::store_shared(10);
+        let (reader, writer) = reflector::store_shared(10);
         let mut subscriber = pin!(writer.subscribe().unwrap());
         let mut other_subscriber = pin!(writer.subscribe().unwrap());
         let mut reflect = pin!(st.reflect_shared(writer));
@@ -249,8 +250,11 @@ pub(crate) mod test {
             poll!(reflect.next()),
             Poll::Ready(Some(Ok(Event::Delete(_))))
         ));
+        assert_eq!(reader.get(&ObjectRef::from_obj(&foo)), Some(foo.clone()));
         assert_eq!(poll!(subscriber.next()), Poll::Ready(Some(foo.clone())));
+        assert_eq!(reader.get(&ObjectRef::from_obj(&foo)), Some(foo.clone()));
         assert_eq!(poll!(other_subscriber.next()), Poll::Ready(Some(foo.clone())));
+        assert_eq!(reader.get(&ObjectRef::from_obj(&foo)), None);
 
         assert!(matches!(
             poll!(reflect.next()),

kube-runtime/src/reflector/store.rs

@@ -258,7 +258,7 @@ where
                     key.extra.remaining_lookups = Some(lookups - 1);
                     store.insert(key, obj.clone());
                 }
-            };
+            }
 
             obj
         })