Example: Close session packet sent before starting a new transmission

examples/flute-receiver/src/main.rs

@@ -29,9 +29,12 @@ fn main() {
 
     log::info!("Create FLUTE, write objects to {:?}", dest_dir);
 
+    let mut config = flute::receiver::Config::default();
+    config.object_receive_once = true; // receive objects only once. If the same object is repeated, it will be ignored
+
     let enable_md5_check = true;
     let writer = Rc::new(writer::ObjectWriterFSBuilder::new(dest_dir, enable_md5_check).unwrap());
-    let mut receiver = MultiReceiver::new(writer, None, false);
+    let mut receiver = MultiReceiver::new(writer, Some(config), false);
 
     // Receive from 224.0.0.1:3400 on 127.0.0.1 (lo) interface
     let socket = msocket::MSocket::new(&endpoint, Some("127.0.0.1"), false)

examples/flute-sender/src/main.rs

@@ -1,6 +1,6 @@
 use flute::{
-    core::UDPEndpoint,
     core::lct::Cenc,
+    core::UDPEndpoint,
     sender::{ObjectDesc, Sender},
 };
 use std::{net::UdpSocket, time::SystemTime};
@@ -54,14 +54,19 @@ fn main() {
             true,
         )
         .unwrap();
-        sender.add_object(0, obj).unwrap();
+        sender.add_object(0, obj).expect("Add object failed");
     }
 
     log::info!("Publish FDT update");
-    sender.publish(SystemTime::now()).unwrap();
+    sender.publish(SystemTime::now()).expect("Publish failed");
+
+    // Send a "close session" packet to notify the receiver that the
+    // previous session should be terminated,  a new one is about to start.
+    let close_session_pkt = sender.read_close_session(SystemTime::now());
+    udp_socket.send(&close_session_pkt).expect("Send failed");
 
     while let Some(pkt) = sender.read(SystemTime::now()) {
-        udp_socket.send(&pkt).unwrap();
+        udp_socket.send(&pkt).expect("Send failed");
         std::thread::sleep(std::time::Duration::from_millis(1));
     }
 }