public static ITalkTarget GetTalkTarget(objectsCamera cam, IAudioSource source)
        {
            ITalkTarget talkTarget;

            switch (cam.settings.audiomodel)
            {
                default://local playback
                    talkTarget = new TalkLocal(source);
                    break;
                case "Foscam":
                    talkTarget = new TalkFoscam(cam.settings.audioip, cam.settings.audioport,
                        cam.settings.audiousername, cam.settings.audiopassword, source);
                    break;
                case "iSpyServer":
                    talkTarget = new TalkiSpyServer(cam.settings.audioip, cam.settings.audioport,
                        source);
                    break;
                case "NetworkKinect":
                    talkTarget = new TalkNetworkKinect(cam.settings.audioip, cam.settings.audioport,
                        source);
                    break;
                case "Axis":
                    talkTarget = new TalkAxis(cam.settings.audioip, cam.settings.audioport,
                        cam.settings.audiousername, cam.settings.audiopassword, source);
                    break;
                case "IP Webcam (Android)":
                    talkTarget = new TalkIPWebcamAndroid(new Uri(cam.settings.videosourcestring), source);
                    break;
            }
            return talkTarget;
        }

 public RemoteFlacEncoder(IPAddress remoteAddress, IAudioSource audioSource, string targetFilename, AudioFileTag tags, int compressionLevel, TrackGain trackGain, DrMeter drMeter)
     : base(audioSource, targetFilename, tags, trackGain, drMeter)
 {
     this.AudioDest = new RemoteFlacWriter(remoteAddress, targetFilename, audioSource.PCM)
     {
         CompressionLevel = compressionLevel
     };
 }

 public LocalMp3Encoder(IAudioSource audioSource, string targetFilename, AudioFileTag tags, int vbrQuality, TrackGain trackGain, DrMeter drMeter)
     : base(audioSource, targetFilename, tags, trackGain, drMeter)
 {
     this.AudioDest = new LameWriter(targetFilename, audioSource.PCM)
     {
         Settings = LameWriterSettings.CreateVbr(vbrQuality)
     };
 }

 public CueToolsFlacEncoder(IAudioSource audioSource, string targetFilename, AudioFileTag tags, int compressionLevel, TrackGain trackGain, DrMeter drMeter)
     : base(audioSource, targetFilename, tags, trackGain, drMeter)
 {
     this.AudioDest = new FLACWriter(targetFilename, audioSource.PCM)
     {
         CompressionLevel = compressionLevel
     };
 }

 public TalkAxis(string server, int port, string username, string password, IAudioSource audioSource)
 {
     _server = server;
     _port = port;
     _audioSource = audioSource;
     _username = username;
     _password = password;
 }

 public static TrackGain CreateTrackGain(IAudioSource audioSource)
 {
     if (audioSource != null && ReplayGain.IsSupportedFormat(audioSource.PCM.SampleRate, audioSource.PCM.BitsPerSample))
     {
         return new TrackGain(audioSource.PCM.SampleRate, audioSource.PCM.BitsPerSample);
     }
     return null;
 }

 public RemoteMp3VbrEncoder(IPAddress remoteAddress, IAudioSource audioSource, string targetFilename, AudioFileTag tags, int vbrQuality, TrackGain trackGain, DrMeter drMeter)
     : base(audioSource, targetFilename, tags, trackGain, drMeter)
 {
     this.AudioDest = new RemoteMp3VbrWriter(remoteAddress, targetFilename, audioSource.PCM)
     {
         CompressionLevel = vbrQuality
     };
 }

 /// <summary>
 /// Adds a source/sink combination to this muxer
 /// </summary>
 /// <param name="source"></param>
 /// <param name="sink"></param>
 public PushPullObject AddInputOutputSource(IAudioSource source, IAudioSink sink)
 {
     PushPullObject member = new PushPullObject(source, sink);
     lock (MemberLock)
     {
         Members.Add(member);
     }
     return member;
 }

 public AudioPipe(IAudioSource source, int size, bool own, ThreadPriority priority)
     : this(source.PCM, size)
 {
     this.own = own;
     this.priority = priority;
     _source = source;
     _sampleLen = _source.Length;
     _samplePos = _source.Position;
 }

    public TestableExample(TestableGameObject parent,
        IAudioSource source,
        Sphere sphere,
        [Resource("audio/beep")] AudioClip beep)
        : base(parent)
    {
        this.source = source;
        this.beep = beep;

        this.Obj.transform.localScale = new Vector3(5, 5, 5);
    }

        public FileEncoderBase(IAudioSource audioSource, string targetFilename, AudioFileTag tags, TrackGain trackGain, DrMeter drMeter)
        {
            if (audioSource == null)
            {
                throw new SkipEncodingItemException("Unsupported audio source.");
            }

            this.targetFilename = targetFilename;
            this.audioSource = audioSource;
            Directory.CreateDirectory(Path.GetDirectoryName(this.targetFilename));
            this.tags = tags;
            this.trackGain = trackGain;
            this.drMeter = drMeter;
        }

        public LossyWAVReader(IAudioSource audioSource, IAudioSource lwcdfSource)
        {
            _audioSource = audioSource;
            _lwcdfSource = lwcdfSource;

            if (_audioSource.Length != _lwcdfSource.Length)
                throw new Exception("Data not same length");
            if (_audioSource.PCM.BitsPerSample != _lwcdfSource.PCM.BitsPerSample
                || _audioSource.PCM.ChannelCount != _lwcdfSource.PCM.ChannelCount
                || _audioSource.PCM.SampleRate != _lwcdfSource.PCM.SampleRate)
                throw new Exception("FMT Data mismatch");

            scaling_factor = 1.0; // !!!! Need to read 'fact' chunks or tags here
        }

        protected override IEncoder CreateEncoderInternal(int threadNumber, FileEncodeTask task, IAudioSource audioSource)
        {
            if (threadNumber < this.localConcurrency)
            {
                return new LocalMp3Encoder(audioSource, task.TargetFilename, task.Tag, vbrQuality, task.TrackGain, task.DrMeter);
            }

            threadNumber -= Environment.ProcessorCount;

            foreach (DiscoveryServerDescriptor server in this.servers)
            {
                if (threadNumber < server.ThreadCount)
                {
                    return new RemoteMp3VbrEncoder(server.Address, audioSource, task.TargetFilename, task.Tag, this.vbrQuality, task.TrackGain, task.DrMeter);
                }
                threadNumber -= server.ThreadCount;
            }

            throw new ArgumentException("threadNumber is too large.");
        }

        protected override IEncoder CreateEncoderInternal(int threadNumber, FileEncodeTask task, IAudioSource audioSource)
        {
            if (threadNumber < this.concurrencylevel)
            {
                return new NativeFlacEncoder(audioSource, task.TargetFilename, task.Tag, compressionLevel, task.TrackGain, task.DrMeter);
            }

            threadNumber -= this.concurrencylevel;

            foreach (DiscoveryServerDescriptor server in this.servers)
            {
                if (threadNumber < server.ThreadCount)
                {
                    return new RemoteFlacEncoder(server.Address, audioSource, task.TargetFilename, task.Tag, this.compressionLevel, task.TrackGain, task.DrMeter);
                }
                threadNumber -= server.ThreadCount;
            }

            throw new ArgumentException("threadNumber is too large.");
        }

        public void RemoveInputOutputSource(IAudioSource source, IAudioSink sink)
        {
            lock (MemberLock)
            {
                PushPullObject removeobject = null;
                foreach (PushPullObject ppo in Members)
                {
                    if ((ppo.AudioSource == source) && (ppo.AudioSink == sink))
                    {
                        removeobject = ppo;
                        break;
                    }
                }

                if (removeobject != null)
                {
                    Members.Remove(removeobject);
                }
            }
        }

 public TalkIPWebcamAndroid(Uri server,IAudioSource audioSource)
 {
     _server = server;
     _audioSource = audioSource;
 }

 public static DrMeter CreateDrMeter(IAudioSource audioSource)
 {
     return new DrMeter(audioSource.PCM.ChannelCount, audioSource.PCM.SampleRate, audioSource.PCM.BitsPerSample);
 }

 public DspCalculatorEncoder(IAudioSource audioSource, TrackGain trackGain, DrMeter drMeter)
 {
     this.audioSource = audioSource;
     this.trackGain = trackGain;
     this.drMeter = drMeter;
 }

        public void Enable()
        {
            if (_enabling)
                return;
            if (InvokeRequired)
            {
                Invoke(new Delegates.EnableDelegate(Enable));
                return;
            }

            lock (_lockobject)
            {
                if (IsEnabled)
                    return;
                IsEnabled = true;
            }
            _enabling = true;

            try
            {

                if (CameraControl != null)
                {
                    Width = CameraControl.Width;
                    Location = new Point(CameraControl.Location.X, CameraControl.Location.Y + CameraControl.Height);
                    Width = Width;
                    Height = 50;
                    if (!CameraControl.IsEnabled)
                    {
                        CameraControl.Enable();
                    }
                }

                IsEnabled = true;
                IsReconnect = false;

                int channels = Micobject.settings.channels;
                int sampleRate = Micobject.settings.samples;
                const int bitsPerSample = 16;

                if (channels < 1)
                {
                    channels = Micobject.settings.channels = 1;

                }
                if (sampleRate < 8000)
                {
                    sampleRate = Micobject.settings.samples = 8000;
                }

                IsClone = Micobject.settings.typeindex==5 || (CameraControl != null && CameraControl.Camobject.settings.sourceindex == 10 &&
                          Micobject.settings.typeindex == 4);

                switch (Micobject.settings.typeindex)
                {
                    case 0: //usb
                        AudioSource = new LocalDeviceStream(Micobject.settings.sourcename)
                                      {RecordingFormat = new WaveFormat(sampleRate, bitsPerSample, channels)};
                        break;
                    case 1: //ispy server (fixed waveformat at the moment...)
                        AudioSource = new iSpyServerStream(Micobject.settings.sourcename)
                                      {RecordingFormat = new WaveFormat(8000, 16, 1)};
                        break;
                    case 2: //VLC listener
                        List<String> inargs = Micobject.settings.vlcargs.Split(Environment.NewLine.ToCharArray(),
                            StringSplitOptions.RemoveEmptyEntries).
                            ToList();
                        //switch off video output
                        inargs.Add(":sout=#transcode{vcodec=none}:Display");

                        AudioSource = new VLCStream(Micobject.settings.sourcename, inargs.ToArray())
                                      {
                                          RecordingFormat = new WaveFormat(sampleRate, bitsPerSample, channels),
                                          TimeOut = Micobject.settings.timeout
                                      };
                        break;
                    case 3: //FFMPEG listener
                        AudioSource = new FFMPEGAudioStream(Micobject.settings.sourcename)
                                      {
                                          RecordingFormat = new WaveFormat(sampleRate, bitsPerSample, channels),
                                          AnalyseDuration = Micobject.settings.analyzeduration,
                                          Timeout = Micobject.settings.timeout
                                      };
                        break;
                    case 4: //From Camera Feed
                        AudioSource = null;
                        if (CameraControl != null)
                        {
                            if (CameraControl.Camera != null)
                            {
                                AudioSource = CameraControl.Camera.VideoSource as IAudioSource;
                                if (AudioSource == null)
                                {
                                    if (IsClone)
                                    {
                                        //cloned feed
                                        int icam = Convert.ToInt32(CameraControl.Camobject.settings.videosourcestring);

                                            var cw = MainForm.InstanceReference.GetCameraWindow(icam);
                                            if (cw != null)
//.........这里部分代码省略.........

        /// <summary>
        ///   Starts capturing from the chosen audio input interface
        /// </summary>
        /// 
        void btnStart_Click(object sender, EventArgs e)
        {
            // Get the device currently selected in the combobox
            AudioDeviceInfo info = comboBox1.SelectedItem as AudioDeviceInfo;

            if (info == null)
            {
                MessageBox.Show("No audio devices available.");
                return;
            }

            // Create a new audio capture device
            source = new AudioCaptureDevice(info)
            {
                // Capture at 22050 Hz
                DesiredFrameSize = 2048,
                SampleRate = 22050
            };

            // Wire up some notification events
            source.NewFrame += source_NewFrame;
            source.AudioSourceError += source_AudioSourceError;
            

            // Start it!
            source.Start();
        }