split/monofile
1
0
Fork 0
mirror of https://github.com/mollersuite/monofile.git synced 2024-11-22 05:46:26 -08:00
Code Issues Actions Packages Projects Releases 1 Wiki Activity

todo another rework of readfilestream yay

Browse source
This commit is contained in:
May 2023-12-22 22:03:01 -08:00
parent c5040e1b79
commit 37216c8166
1 changed files with 22 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

26
src/server/lib/files.ts
View file

@ -79,13 +79,13 @@ export interface StatusCodeError {
message: string message: string
} }
// this is probably really stupid. I'm sorry! /**
* @description This function does not respect backpressure and should be worked out of the codebase. Superseded by startPushingWebStream()
type ResolveType<T extends Promise<any>> = T extends Promise<infer U> ? U: never; */
async function pushWebStream(stream: Readable, webStream: ReadableStream) { async function pushWebStream(stream: Readable, webStream: ReadableStream) {
const reader = await webStream.getReader() const reader = await webStream.getReader()
let result: ResolveType<ReturnType<typeof reader.read>> = { done: false, value: undefined } let result: Awaited<ReturnType<typeof reader.read>> = { done: false, value: undefined }
let last = true let last = true
while ( !result.done ) { while ( !result.done ) {
@ -95,6 +95,24 @@ async function pushWebStream(stream: Readable, webStream: ReadableStream) {
return last return last
} }
async function startPushingWebStream(stream: Readable, webStream: ReadableStream) {
const reader = await webStream.getReader()
let pushing = false // acts as a debounce just in case
// (words of a girl paranoid from writing readfilestream)
return function() {
if (pushing) return
pushing = true
return reader.read().then(result => {
if (result.value)
stream.push(result.value)
pushing = false
return result.done
})
}
}
namespace StreamHelpers { namespace StreamHelpers {
export interface UploadStream { export interface UploadStream {