()
| 324 | |
| 325 | #[tokio::test] |
| 326 | async fn sender_drop() { |
| 327 | let (tx, rx) = create::<i32>(2); |
| 328 | tx.send(1).unwrap(); |
| 329 | drop(tx); |
| 330 | |
| 331 | assert!(rx.is_closed()); |
| 332 | // Should receive BufferClosedError after sender is dropped |
| 333 | assert!(rx.recv().await.is_err()); |
| 334 | } |
| 335 | |
| 336 | #[tokio::test] |
| 337 | async fn receiver_drop() { |