#[cfg(feature = "async")]
use flume::*;

#[cfg(feature = "async")]
#[async_std::test]
async fn sender() {
    let (sender, receiver) = bounded(1);

    let sender_fut = sender.send_async(());
    assert_eq!(sender.is_disconnected(), sender_fut.is_disconnected());
    assert_eq!(sender.is_empty(), sender_fut.is_empty());
    assert_eq!(sender.is_full(), sender_fut.is_full());
    assert_eq!(sender.len(), sender_fut.len());
    assert_eq!(sender.capacity(), sender_fut.capacity());

    let sender_sink = sender.sink();
    assert_eq!(sender.is_disconnected(), sender_sink.is_disconnected());
    assert_eq!(sender.is_empty(), sender_sink.is_empty());
    assert_eq!(sender.is_full(), sender_sink.is_full());
    assert_eq!(sender.len(), sender_sink.len());
    assert_eq!(sender.capacity(), sender_sink.capacity());

    let receiver_fut = receiver.recv_async();
    assert_eq!(receiver.is_disconnected(), receiver_fut.is_disconnected());
    assert_eq!(receiver.is_empty(), receiver_fut.is_empty());
    assert_eq!(receiver.is_full(), receiver_fut.is_full());
    assert_eq!(receiver.len(), receiver_fut.len());
    assert_eq!(receiver.capacity(), receiver_fut.capacity());

    let receiver_stream = receiver.stream();
    assert_eq!(
        receiver.is_disconnected(),
        receiver_stream.is_disconnected()
    );
    assert_eq!(receiver.is_empty(), receiver_stream.is_empty());
    assert_eq!(receiver.is_full(), receiver_stream.is_full());
    assert_eq!(receiver.len(), receiver_stream.len());
    assert_eq!(receiver.capacity(), receiver_stream.capacity());
}