RxAndroidAudio

allprojects {
    repositories {
        mavenCentral()
    }
}
implementation 'com.gitee.ts_ohos:rxohosaudio:1.0.0'
implementation 'com.gitee.ts_ohos:audioProcessor:1.0.0'

Запись аудиофайла осуществляется следующими методами:

```java
mAudiorecorder.prepareRecord(source, Recorder.OutputFormat.MPEG_4,
                             audiopropery, storageproperty);
mAudiorecorder.startRecord();
// ...
mAudiorecorder.stopRecord();

mRxAudioPlayer.play(PlayConfig.file(audioFile).looping(true).build())
        .subscribeOn(Schedulers.io())
        .observeOn(HarmonySchedulers.mainThread())
        .subscribe(new Observer<Boolean>() {
            @Override
            public void onSubscribe(final Disposable disposable) {

            }

            @Override
            public void onNext(final Boolean aBoolean) {
                // готово к проигрыванию
            }
        });
```            @Override
            public void onError(final Throwable throwable) {

            }

            @Override
            public void onComplete() {
                // завершение проигрывания
                // ВАЖНОЕ УПРАЖНЕНИЕ: если воспроизведение циклическое, то Observable никогда не завершится, вам потребуется остановить воспроизведение
                // в onDestroy, иначе произойдет утечка памяти!
            }
        });

PlayConfig.file(audioFile) // проигрывание локального файла
    //.res(getApplicationContext(), R.raw.audio_record_end) // или проигрывание ресурса raw
    .looping(true) // циклическое воспроизведение или нет
    .leftVolume(1.0F) // громкость слева, но данный проигрыватель не поддерживает отдельную регулировку громкости слева и справа
    .rightVolume(1.0F) // громкость справа, но данный проигрыватель не поддерживает отдельную регулировку громкости слева и справа
    .build(); // сборка конфигурации и запуск!

@Override
public void onError() {
    new EventHandler(EventRunner.getMainEventRunner()).postSyncTask(new Runnable() {
        @Override
        public void run() {
            new ToastDialog(StreamAbility.this).setText("Запись не удалась").setDuration(DIALOG_DURATION).show();
            mBtnStart.setText("Старт");
            mIsRecording = false;
        }
    });
}
}### Проигрывание аудио потока (Play a stream)

<img src="./pic/audioStreamPlay.jpg" alt="Проигрывание аудио потока" style="zoom:25%;" div align=center />

```java
Observable.just(mOutputFile).subscribeOn(Schedulers.io()).subscribe(new Action1<File>() {
    @Override
    public void call(File file) {
        try {
            mStreamAudioPlayer.init();
            FileInputStream inputStream = new FileInputStream(file);
            int read;
            while ((read = inputStream.read(mBuffer)) > 0) {
                mStreamAudioPlayer.play(mBuffer, read);
            }
            inputStream.close();
            mStreamAudioPlayer.release();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
});

mStreamAudioPlayer.play(
    mAudioProcessor.process(mRatio, mBuffer, StreamAudioRecorder.DEFAULT_SAMPLE_RATE),
    read);