Harvmaster/xo-cash-utils
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix formatting

Browse Source
This commit is contained in:
Harvmaster
2026-07-19 14:03:09 +00:00
parent 3dd1766ef0
commit a395596883
2 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
source/sse-session/async-push-iterator.ts
View File

@@ -35,7 +35,7 @@ export class AsyncPushIterator<T> {
// `start`'s `this` is the underlying source object when using a plain method. // `start`'s `this` is the underlying source object when using a plain method.
// An arrow function captures the class instance so the controller is stored here. // An arrow function captures the class instance so the controller is stored here.
this.stream = new ReadableStream({ this.stream = new ReadableStream({
start: (controller: ReadableStreamDefaultController<T>) => { start: (controller: ReadableStreamDefaultController<T>): void => {
this.controller = controller; this.controller = controller;
}, },
}); });
@@ -76,7 +76,7 @@ export class AsyncPushIterator<T> {
* Uses `preventCancel: true` so early `break` from `for await...of` does not * Uses `preventCancel: true` so early `break` from `for await...of` does not
* close the stream and block later pushes. * close the stream and block later pushes.
*/ */
[Symbol.asyncIterator]() { [Symbol.asyncIterator](): AsyncIterableIterator<T> {
return this.stream.values({ preventCancel: true }); return this.stream.values({ preventCancel: true });
} }
} }

10
test/sse-session/async-push-iterator.test.ts
View File

@@ -24,7 +24,7 @@ const testPushComposedPushAndConsume = async (): Promise<void> => {
const iterator = new AsyncPushIterator<number>(); const iterator = new AsyncPushIterator<number>();
const result = new Promise<number[]>((resolve) => { const result = new Promise<number[]>((resolve) => {
void (async () => { void (async (): Promise<void> => {
resolve(await collectAll(iterator)); resolve(await collectAll(iterator));
})(); })();
}); });
@@ -62,7 +62,7 @@ const testPushComposedResolvesWithNoValues = async (): Promise<void> => {
const iterator = new AsyncPushIterator<number>(); const iterator = new AsyncPushIterator<number>();
const result = new Promise<number[]>((resolve) => { const result = new Promise<number[]>((resolve) => {
void (async () => { void (async (): Promise<void> => {
resolve(await collectAll(iterator)); resolve(await collectAll(iterator));
})(); })();
}); });
@@ -79,7 +79,7 @@ const testPushComposedIgnoresValuesAfterClose = async (): Promise<void> => {
const iterator = new AsyncPushIterator<number>(); const iterator = new AsyncPushIterator<number>();
const result = new Promise<number[]>((resolve) => { const result = new Promise<number[]>((resolve) => {
void (async () => { void (async (): Promise<void> => {
resolve(await collectAll(iterator)); resolve(await collectAll(iterator));
})(); })();
}); });
@@ -106,14 +106,14 @@ const testPushComposedRejectsMultipleConsumers = async (): Promise<void> => {
const successfulIterator = (): Promise<number[]> => const successfulIterator = (): Promise<number[]> =>
new Promise((resolve) => { new Promise((resolve) => {
void (async () => { void (async (): Promise<void> => {
resolve(await collectAll(iterator)); resolve(await collectAll(iterator));
})(); })();
}); });
const failedIterator = (): Promise<void> => const failedIterator = (): Promise<void> =>
new Promise((resolve, reject) => { new Promise((resolve, reject) => {
void (async () => { void (async (): Promise<void> => {
try { try {
/* eslint-disable-next-line */ /* eslint-disable-next-line */
for await (const _value of iterator) { for await (const _value of iterator) {