Потоковое аудио с весеннего сервера ⇐ JAVA

[Anonymous]

У меня проблема с потоковой передачей звука с моего сервера.

Сервер получает некоторый файл с другого сервера с помощью grpc и получает его по частям. После того, как мой сервер получил этот фрагмент, я помещаю его в выходной поток, который доставляет его клиенту. И делайте это, пока внешний сервер не завершит этот процесс.
Я пытаюсь воспроизвести звук по мере его поступления, но проблема в том, что клиент (браузер Chrome) начинает воспроизводить звук только после полная загрузка, хотя в отладчике я вижу, что байты текут.
У меня есть простой java(spring) сервер:

Код: Выделить всё

    

org.springframework.boot
spring-boot-starter-web
3.3.0


org.springframework.boot
spring-boot-starter-thymeleaf
3.3.0

Код: Выделить всё

@RestController
@RequestMapping("/api/stream")
public class StreamRestController {

private final GrpcServive grpcService = new GrpcServive();

@GetMapping
public void stream(final HttpServletResponse response) throws Exception {
StreamObserverPublisher streamObserverPublisher = new StreamObserverPublisher();
final OutputStream os = response.getOutputStream();

streamObserverPublisher.subscribe(new Flow.Subscriber() {
@Override
public void onSubscribe(Flow.Subscription s) {
// Ignored...
}

@Override
public void onNext(byte[] bytes) {
try {
os.write(bytes);
response.flushBuffer();

} catch (IOException e) {
throw new RuntimeException(e);
}
}

@Override
public void onError(Throwable t) {
try {
os.close();
} catch (IOException e) {
throw new RuntimeException(e);
}
throw new RuntimeException(t);
}

@Override
public void onComplete() {
try {
os.close();
} catch (IOException e) {
throw new RuntimeException(e);
}
}
});

grpcService.synthesize(createRequest(), streamObserverPublisher);

response.setStatus(200);
response.setContentType("audio/wav");
response.addHeader("Cache-Control", "no-cache, no-store");
response.addHeader("Connection", "keep-alive");
response.addHeader("Content-Transfer-Encoding", "chunked");
response.addHeader("Accept-Ranges", "bytes");
}

private Synthesis.SynthesisRequest createRequest() {
return Synthesis.SynthesisRequest.newBuilder()
.setText("One, two, three, four, five, six, seven, eight, nine, ten.")
.setContentType(TEXT)
.setVoice("Kin_8000")
.setAudioEncoding(WAV)
.build();
}
}

Код: Выделить всё

public class StreamObserverPublisher implements Flow.Publisher, StreamObserver {

public Flow.Subscriber

Подробнее здесь: [url]https://stackoverflow.com/questions/78683546/audio-streaming-from-spring-server[/url]