Your API could use SSE (Server Sent Event). It's an open connection that keeps sending data over.
I don't know about Angular or RxJS, but there is EventSource:
const client = new EventSource('/endpoint')
client.onmessage = ev => {
console.log(ev.data)
}
You can also use the fetch response body .getReader() and work with the readable stream.