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

sclass AudioInputDispatcher {
  new Flag stopFlag;
  short[] convertedBuf;
  L<VF1<short[]>> audioListeners;
  SimpleLiveValue<Float> lvVolume;
  bool cloneDataOnce;
  bool verbose;
  O currentListener; // who is holding up audio processing

  *(int bufSize) {
    convertedBuf = new short[bufSize/2];
  }
  
  void handleData(byte[] data) {
    handleData(data, l(data));
  }
  
  void handleData(byte[] data, int n) {
    if (verbose) printWithMilliseconds("Handling audio data (" + nBytes(n) + ", first: " + first(data) + ")");
    pcall {
      bytesToShorts_littleEndian(data, convertedBuf, n);
      short[] convertedData = subShortArray(convertedBuf, 0, n/2);
      if (lvVolume != null) {
        float vol = shortSamplesToPercentVolume(convertedData);
        if (verbose) {
          printStruct(subShortArray(convertedData, 0, 5));
          //print("Volume: " + vol);
        }
        lvSet(lvVolume, vol);
      }
  
      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");
  }
}

Began life as a copy of #1018247