(value: ResourceStreamItem<T>)
| 390 | const promise = new Promise<Signal<ResourceStreamItem<T>>>((r) => (resolve = r)); |
| 391 | |
| 392 | const send = (value: ResourceStreamItem<T>): void => { |
| 393 | stream.set(value); |
| 394 | resolve?.(stream); |
| 395 | resolve = undefined; |
| 396 | }; |
| 397 | |
| 398 | sub = this.client.request(request!).subscribe({ |
| 399 | next: (event) => { |