new
StreamingApi(writable: WritableStream,_readable: ReadableStream,)
private
abortSubscribers: (() => void | Promise<void>)[]
private
encoder: TextEncoder
private
writable: WritableStream
private
writer: WritableStreamDefaultWriter<Uint8Array>
abort(): void
Abort the stream. You can call this method when stream is aborted by external event.
pipe(body: ReadableStream): Promise<void>
write(input: Uint8Array | string): Promise<StreamingApi>
writeln(input: string): Promise<StreamingApi>