//! Tests for StreamingCollector

use mecha10_diagnostics::collectors::streaming::StreamingCollector;

#[test]
fn test_streaming_collector() {
    let collector = StreamingCollector::new("test");

    collector.record_frame_received();
    collector.record_frame_encoded(5000);
    collector.record_frame_sent(10000);

    assert_eq!(collector.frames_received.get(), 1);
    assert_eq!(collector.frames_encoded.get(), 1);
    assert_eq!(collector.frames_sent.get(), 1);
    assert_eq!(collector.bytes_sent.get(), 10000);
}
