Function basic_send_receive

clock-bound/src/daemon/async_ring_buffer.rs:305–312

()

    #[tokio::test]
    async fn basic_send_receive() {
        let (tx, rx) = create(2);
        tx.send(1).unwrap();
        tx.send(2).unwrap();

        assert_eq!(rx.recv().await.unwrap(), 1);
        assert_eq!(rx.recv().await.unwrap(), 2);
    }

    #[tokio::test]
    async fn buffer_overflow() {