!7

import static x30_pkg.x30_util.VF1;

sclass AudioInputOutput > DynPrintLog {

  int bufSize = 40960;

  transient recordToAudioListeners_AudioLoop loop;

  transient SimpleLiveValue<Float> lvVolume = floatLiveValue(); // in percent

  L<VF1<short[]>> audioListeners = synchroList();

  float gain = 1;

  transient playAudioFromSampleMakingFunction_AudioLoop outputLoop;

  transient L<VF1<double[]>> sources = synchroList();

  visualize {

    ret centerAndSouthWithMargins(super.visualize(),

      vstackWithSpacing(

        withLabel("Volume (0-200%):", liveSliderZeroToOne(gain/2, voidfunc(float f) { setField(gain := f*2) })),

        jCenteredLine(jLiveValueLabel(mapLiveValue(func(float volume) -> S { "Input Volume: " + iround(volume) + " %" }, S, lvVolume)))));

  }

  start {

    ownTimer(loop = recordToAudioListeners(audioListeners, bufSize, lvVolume));

    ownTimer(outputLoop = playAudioFromSampleMakingFunction_dontStart(bufSize, voidfunc(double[] pair) {

      audio_makeSampleFromSources(sources, pair, gain)

    }));

    Mixer mixer = AudioSystem.getMixer(null);

    print("Mixer: " + mixer);

    Line[] lines = { loop.line, outputLoop.out };

    bool fullSync = true;

    bool canSync = mixer.isSynchronizationSupported(lines, true);

    print("Can sync: " + canSync);

    if (!canSync) {

      fullSync = false;

      canSync = mixer.isSynchronizationSupported(lines, false);

      print("Can sync: " + canSync);

    }

    if (canSync)

      mixer.synchronize(lines, fullSync);

    loop.start();

    outputLoop.start();

  }

  void addAudioListener(VF1<short[]> l) { audioListeners.add(l); }

  void removeAudioListener(VF1<short[]> l) { audioListeners.remove(l); }

  void addSource(VF1<double[]> source) { sources.add(source); }

  void removeSource(VF1<double[]> source) { sources.remove(source); }

}