()
| 313 | |
| 314 | #[tokio::test] |
| 315 | async fn buffer_overflow() { |
| 316 | let (tx, rx) = create(2); |
| 317 | tx.send(1).unwrap(); |
| 318 | tx.send(2).unwrap(); |
| 319 | tx.send(3).unwrap(); // This should overwrite the oldest value (1) |
| 320 | |
| 321 | assert_eq!(rx.recv().await.unwrap(), 2); // First value (1) was overwritten |
| 322 | assert_eq!(rx.recv().await.unwrap(), 3); |
| 323 | } |
| 324 | |
| 325 | #[tokio::test] |
| 326 | async fn sender_drop() { |