nspeex.reactive.cs

    [TestFixture]
    public class SpeakerTest
    {
        private IVoiceCapture _capture;
        private IVoiceSpeaker _speaker;

        [SetUp]
        public void Setup()
        {
            _capture = new VoiceCapture(8000, 250);
            _speaker = new VoiceSpeaker(8000);
        }

        [TearDown]
        public void Tear()
        {
            _capture.Dispose();
        }
        
        [Test]
        public void NSpeexTest()
        {
            var encoder = new EncodeSubject(BandMode.Narrow);
            var decoder = new DecodeSubject(BandMode.Narrow);
            var _stopwatch = Stopwatch.StartNew();
            _capture.Subscribe(b =>
            {
                var time = _stopwatch.ElapsedMilliseconds;
                Debug.WriteLine($"{time}msec PCM {b.Length}");
            });
            _capture.Subscribe(encoder);
            encoder.Subscribe(b =>
            {
                var time = _stopwatch.ElapsedMilliseconds;
                Debug.WriteLine($"{time}msec eSPX {b.Length}");
            });
            encoder.Subscribe(decoder);
            decoder.Subscribe(b =>
            {
                var time = _stopwatch.ElapsedMilliseconds;
                Debug.WriteLine($"{time}msec dSPX {b.Length}");
            });
            decoder.Delay(TimeSpan.FromMilliseconds(1000)).Subscribe(_speaker);
            _capture.Start();
            Thread.Sleep(5000);
        }