scope androidSay_keepEngine.

import android.app.Activity;
import android.speech.tts.*;

sbool #verbose, #inCall;
static TextToSpeech #tts;

// TODO: better way to sync than synchronizing on main class

static synchronized void androidSay_keepEngine(final S text, final Locale locale) {
  final new Flag flag;
  
  if (tts == null) {
    if (verbose) print("Initialising TTS");
    tts = new TextToSpeech(androidContext(), new TextToSpeech.OnInitListener() {
      public void onInit(int status) {
        try {
          if (status != TextToSpeech.SUCCESS)
            fail("Speech engine initialization failed");
    
          go(text, locale, flag);
        } catch (Throwable e) { e.printStackTrace(); flag.raise(); }
      }
    });
    if (verbose) print("TTS object created");
  } else
    androidSay_keepEngine_go(text, locale, flag);
    
  flag.waitUntilUp();
}

static void #go(S text, Locale locale, final Flag flag) {
  if (verbose) print("TTS go: " + text);
  int result = tts.setLanguage(locale);
  if (result == TextToSpeech.LANG_MISSING_DATA
    || result == TextToSpeech.LANG_NOT_SUPPORTED)
    fail("German is not supported");
    
  /*if (empty(text)) { // Empty text = Initialize engine only
    flag.raise();
    ret;
  }*/

  result = tts.setOnUtteranceProgressListener(new UtteranceProgressListener() {
    public void onDone(String utteranceId) {
      print("TTS done");
      flag.raise();
    }

    public void onError(String utteranceId) {
      print("TTS error");
      flag.raise();
    }

    public void onStart(String utteranceId) {
      if (verbose) print("TTS started");
    }
  });
  
  if (result != TextToSpeech.SUCCESS)
    print("Could not set listener");
      
  //if (nempty(text)) print("[speech output] " + text);
  new HashMap params;
  params.put(TextToSpeech.Engine.KEY_PARAM_UTTERANCE_ID, randomID(8));
  if (inCall)
    params.put(TextToSpeech.Engine.KEY_PARAM_STREAM, str(AudioManager.STREAM_VOICE_CALL));
  tts.speak(text, TextToSpeech.QUEUE_FLUSH, params);
}

end scope