processStream method

@override Stream<List<int>> processStream(Stream<List<int>> inputStream)

Process audio stream (for real-time)

Implementation

@override
Stream<List<int>> processStream(Stream<List<int>> inputStream) async* {
  await for (final chunk in inputStream) {
    final processed = await processAudioData(chunk);
    if (processed != null) {
      yield processed;
    }
  }
}