Clippy test fixes.

Signed-off-by: Sandeep <[email protected]>

integration_test/src/event_writer_tests.rs

@@ -110,7 +110,7 @@ async fn test_simple_write(writer: &mut EventWriter) {
 
     for rx in receivers {
         let reply: Result<(), Error> = rx.await.expect("wait for result from oneshot");
-        assert_eq!(reply.is_ok(), true);
+        assert!(reply.is_ok());
     }
     info!("test simple write passed");
 }
@@ -150,7 +150,7 @@ async fn test_segment_scaling_up(writer: &mut EventWriter, factory: &ClientFacto
 
     for rx in receivers {
         let reply: Result<(), Error> = rx.await.expect("wait for result from oneshot");
-        assert_eq!(reply.is_ok(), true);
+        assert!(reply.is_ok());
     }
 
     info!("test event stream writer with segment scaled up passed");
@@ -189,7 +189,7 @@ async fn test_segment_scaling_down(writer: &mut EventWriter, factory: &ClientFac
 
     for rx in receivers {
         let reply: Result<(), Error> = rx.await.expect("wait for result from oneshot");
-        assert_eq!(reply.is_ok(), true);
+        assert!(reply.is_ok());
     }
     info!("test event stream writer with segment sealed passed");
 }
@@ -198,7 +198,7 @@ async fn test_write_correctness(writer: &mut EventWriter, factory: &ClientFactor
     info!("test read and write");
     let rx = writer.write_event(String::from("event0").into_bytes()).await;
     let reply: Result<(), Error> = rx.await.expect("wait for result from oneshot");
-    assert_eq!(reply.is_ok(), true);
+    assert!(reply.is_ok());
     let scope_name = Scope::from("testScopeWriter2".to_owned());
     let stream_name = Stream::from("testStreamWriter2".to_owned());
     let segment_name = ScopedSegment {
@@ -274,7 +274,7 @@ async fn test_write_correctness_while_scaling(writer: &mut EventWriter, factory:
     // the data should write successfully.
     for rx in receivers {
         let reply: Result<(), Error> = rx.await.expect("wait for result from oneshot");
-        assert_eq!(reply.is_ok(), true);
+        assert!(reply.is_ok());
     }
 
     let segment_name = ScopedSegment {

integration_test/src/table_tests.rs

@@ -298,7 +298,7 @@ async fn test_iterators(client_factory: &ClientFactory) {
             Ok(t) => {
                 let k: String = t.0;
                 info!("key {:?} version {:?}", k, t.1);
-                assert_eq!(false, k.is_empty());
+                assert!(!k.is_empty());
                 key_count += 1;
             }
             _ => panic!("Failed fetch keys."),
@@ -317,8 +317,8 @@ async fn test_iterators(client_factory: &ClientFactory) {
                 let v: String = t.1;
 
                 info!("key {:?} value {:?} version {:?}", k, v, t.2);
-                assert_eq!(false, k.is_empty());
-                assert_eq!(false, v.is_empty());
+                assert!(!k.is_empty());
+                assert!(!v.is_empty());
                 entry_count += 1;
             }
             _ => panic!("Failed fetch entries."),

src/segment/selector.rs

@@ -278,6 +278,7 @@ pub(crate) mod test {
                     retention_type: RetentionType::None,
                     retention_param: 0,
                 },
+                tags: None,
             })
             .await
             .unwrap();