fix(ci): Update CI workflows, dependency versions, and TypeScript configuration
This commit is contained in:
@@ -1,5 +1,5 @@
|
||||
import { Observable } from 'rxjs';
|
||||
import { Readable } from 'stream';
|
||||
import type { Readable } from 'stream';
|
||||
|
||||
export function fromStreamWithBackpressure<T>(stream: Readable): Observable<T> {
|
||||
return new Observable<T>((subscriber) => {
|
||||
@@ -29,4 +29,4 @@ export function fromStreamWithBackpressure<T>(stream: Readable): Observable<T> {
|
||||
stream.removeListener('close', subscriber.complete);
|
||||
};
|
||||
});
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user