Future<void> initialize({
    required int sampleRate,
    required String language,
  }) async {
    sherpa_onnx.initBindings();

    final transducer = sherpa_onnx.OnlineTransducerModelConfig(
      encoder: await _modelLoader.encoderPath(_modelName(language)),
      decoder: await _modelLoader.decoderPath(_modelName(language)),
      joiner: await _modelLoader.joinerPath(_modelName(language)),
    );
    final modelConfig = sherpa_onnx.OnlineModelConfig(
      transducer: transducer,
      tokens: await _modelLoader.tokensPath(_modelName(language)),
    );
    final config = sherpa_onnx.KeywordSpotterConfig(
      model: modelConfig,
      keywordsFile: await _modelLoader.keywordsPath(_modelName(language)),
    );
    _spotter = sherpa_onnx.KeywordSpotter(config);
    _stream = _spotter.createStream();
    _sampleRate = sampleRate;
  }

  String? predict(Uint8List samples) {
    final samplesFloat32 = _convertBytesToFloat32(samples);
    _stream.acceptWaveform(
      samples: samplesFloat32,
      sampleRate: _sampleRate,
    );

    while (_spotter.isReady(_stream)) {
      _spotter.decode(_stream);
    }

    final keyword = _spotter.getResult(_stream).keyword;
    if (keyword.isNotEmpty) {
      print('Detected: $keyword');
      return keyword;
    }

    return null;
  }
}

Float32List _convertBytesToFloat32(
    Uint8List bytes, [
    Endian endian = Endian.little,
  ]) {
    final values = Float32List(bytes.length ~/ 2);

    final data = ByteData.view(bytes.buffer);

    for (var i = 0; i < bytes.length; i  = 2) {
      final short = data.getInt16(i, endian);
      values[i ~/ 2] = short / 32678.0;
    }

    return values;
  }

 await _recorder.startRecorder(
        toStream: _audioController.sink,
        codec: base.Codec.pcm16,
      );

    while (_spotter.isReady(_stream)) {
      _spotter.decode(_stream);
    }

    final keyword = _spotter.getResult(_stream).keyword;
    if (keyword.isNotEmpty) {
      print('Detected: $keyword');
      return keyword;
    }