Add cache test

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

kube-runtime/src/reflector/dispatcher.rs

@@ -152,8 +152,7 @@ where
 #[cfg(test)]
 pub(crate) mod test {
     use crate::{
-        watcher::{Error, Event},
-        WatchStreamExt,
+        reflector::ObjectRef, watcher::{Error, Event}, WatchStreamExt
     };
     use std::{pin::pin, sync::Arc, task::Poll};
 
@@ -239,7 +238,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 +248,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()),