// TODO: copy buffers less (have multiple listeners keep buffers without copying)

static recordToAudioListeners_AudioLoop recordToAudioListeners(L<VF1<short[]>> audioListeners, int bufSize, SimpleLiveValue<Float> lvVolume) {

  recordToAudioListeners_AudioLoop loop = new(bufSize);

  loop.audioListeners = audioListeners;

  loop.lvVolume = lvVolume;

  ret loop;

}

static recordToAudioListeners_AudioLoop recordToAudioListeners(L<VF1<short[]>> audioListeners, int bufSize, SimpleLiveValue<Float> lvVolume, AudioFormat quality) {

  recordToAudioListeners_AudioLoop loop = new(bufSize, quality);

  loop.audioListeners = audioListeners;

  loop.lvVolume = lvVolume;

  ret loop;

}

sclass recordToAudioListeners_AudioLoop extends Thread implements AutoCloseable {

  TargetDataLine line;

  new Flag stopFlag;

  byte[] buf;

  short[] convertedBuf;

  L<VF1<short[]>> audioListeners;

  SimpleLiveValue<Float> lvVolume;

  AudioFormat quality;

  bool cloneDataOnce;

  bool verbose;

  O currentListener; // who is holding up audio processing

  *(int bufSize) {

    this(bufSize, javaSound_cdQuality());

  }

  *(int bufSize, AudioFormat *quality) {

    line = javaSound_recordLine(quality, bufSize);

    buf = new byte[bufSize];

    convertedBuf = new short[bufSize/2];

  }

  public void start { line.start°; super.start°; }

  void stopRecording { // "stop()" was taken

    if (stopFlag.isUp()) ret;

    stopFlag.raise°; line.close°;

    print("Audio input loop stopped.");

  }

  public void close { stopRecording(); }

  public void run° {

    print("Audio input loop started. Buffer size=" + l(buf) + " (" + iround(l(buf)/quality.getSampleRate()/quality.getFrameSize()*1000) + " ms)");

    while (licensed() && !stopFlag.isUp()) {

      int n = line.read(buf, 0, l(buf));

      if (stopFlag.isUp()) break;

      if (n < l(buf)) print("Weird: Got less than a buffer: " + n + "/" + l(buf));

      if (n == 0) ret with print("EMERGENCY STOP.");

      handleData(buf, n);

    }

  }

  void handleData(byte[] data, int n) {

    if (verbose) printWithMilliseconds("Handling audio data (" + nBytes(n) + ")");

    pcall {

      bytesToShorts_littleEndian(data, convertedBuf, n);

      short[] convertedData = subShortArray(convertedBuf, 0, n/2);

      lvSet(lvVolume, shortSamplesToPercentVolume(convertedData));

      if (cloneDataOnce)

        convertedData = cloneShortArray(convertedData);

      for i over audioListeners: { // synchro-safe, garbage-free iteration

        VF1<short[]> l = syncGet(audioListeners, i);

        continue if l == null;

        try {

          currentListener = l;

          pcallF(l, convertedData);

        } finally {

          currentListener = null;

        }

      }

    }

    if (verbose) printWithMilliseconds("Done handling audio data");

  }

}