Я использую канал Okio для чтения и отправки аудиобайтов с микрофона устройства Android, и я хотел бы иметь своего рода предварительный буфер предварительного размера аудио, удаляющий первые полученные байты, когда буфер заполнен, идобавление новых.Кто-нибудь знает, смогу ли я достичь этого с помощью Pipe BufferedSink?Я пытался так:
Pipe pipe = new Pipe(8192);
BufferedSink sink = Okio.buffer(pipe.sink());
Когда я получаю новые данные, я пишу в приемник:
sink.write(data);
Но когда размер внутреннего буфера приемника равен 8192, приемник блокируется, и яне могу добавить больше данных к нему.