diff --git a/src/publish.rs b/src/publish.rs
index 4b99228..8c9725d 100644
--- a/src/publish.rs
+++ b/src/publish.rs
@@ -561,7 +561,10 @@ mod tests {
         assert_eq!(req_data, bincode::serialize(&crusher_req).unwrap());
 
         // send/recv url collector stream request
-        let url_collector_req = RequestUrlCollectorStream { start: 0 };
+        let url_collector_req = RequestUrlCollectorStream {
+            start: 0,
+            source: Some("hello".to_string()),
+        };
         super::send_stream_request(
             &mut channel.client.send,
             super::stream::RequestStreamRecord::Http,
diff --git a/src/publish/stream.rs b/src/publish/stream.rs
index a082bfc..bbe5350 100644
--- a/src/publish/stream.rs
+++ b/src/publish/stream.rs
@@ -130,4 +130,5 @@ pub struct RequestCrusherStream {
 #[allow(clippy::module_name_repetitions)]
 pub struct RequestUrlCollectorStream {
     pub start: i64,
+    pub source: Option<String>,
 }