Diwakar Prasad Diwakar14
😎
markotny
/ fromFetchStream.ts
Last active
October 26, 2023 18:05
Fetch streaming to rxjs (e.g. .NET IAsyncEnumerable)
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| import {Observable} from 'rxjs'; | |
| /** | |
| * Stream server data (e.g. from endpoint returning IAsyncEnumerable) | |
| * @type T type of stream element | |
| * @param input input param of {@link fetch} | |
| * @param init init param of {@link fetch} (excluding abort signal) | |
| * @return stream of array elements one by one | |
| */ | |
| export function fromFetchStream<T>(input: RequestInfo, init?: RequestInit): Observable<T> { |