WaterMarkedUploadStream

Constructors

Link copied to clipboard
constructor(bufferSize: Number)

Properties

Link copied to clipboard
open external override val _construct: (callback: (JsError?) -> Unit) -> Unit?
Link copied to clipboard
open external val _writev: (ReadonlyArray<WritableWritevChunksItem>, callback: (JsError?) -> Unit) -> Unit?
Link copied to clipboard
external var allowHalfOpen: Boolean
Link copied to clipboard
open external override val closed: Boolean
Link copied to clipboard
open external override val closeEvent: EventInstance<Tuple>
Link copied to clipboard
open external override val dataEvent: EventInstance<Tuple1<Any?>>
Link copied to clipboard
open external override var destroyed: Boolean
Link copied to clipboard
open external override val drainEvent: EventInstance<Tuple>
Link copied to clipboard
open external override val endEvent: EventInstance<Tuple>
Link copied to clipboard
open external override val errored: JsError?
Link copied to clipboard
open external override val errorEvent: EventInstance<Tuple1<JsError>>
Link copied to clipboard
open external override val finishEvent: EventInstance<Tuple>
Link copied to clipboard
open external override val pauseEvent: EventInstance<Tuple>
Link copied to clipboard
open external override val pipeEvent: EventInstance<Tuple1<Readable>>
Link copied to clipboard
open external var readable: Boolean
Link copied to clipboard
external val readableAborted: Boolean
Link copied to clipboard
external val readableDidRead: Boolean
Link copied to clipboard
Link copied to clipboard
external val readableEnded: Boolean
Link copied to clipboard
open external override val readableEvent: EventInstance<Tuple>
Link copied to clipboard
external val readableFlowing: Boolean?
Link copied to clipboard
Link copied to clipboard
external val readableLength: Double
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
open external override val resumeEvent: EventInstance<Tuple>
Link copied to clipboard
open external override val unpipeEvent: EventInstance<Tuple1<Readable>>
Link copied to clipboard
open external var writable: Boolean
Link copied to clipboard
external val writableAborted: Boolean
Link copied to clipboard
open external val writableCorked: Double
Link copied to clipboard
open external val writableEnded: Boolean
Link copied to clipboard
open external val writableFinished: Boolean
Link copied to clipboard
open external val writableHighWaterMark: Double
Link copied to clipboard
open external val writableLength: Double
Link copied to clipboard
open external val writableNeedDrain: Boolean
Link copied to clipboard
open external val writableObjectMode: Boolean

Functions

Link copied to clipboard
open external override fun _destroy(error: JsError?, callback: (JsError?) -> Unit)
Link copied to clipboard
open external fun _final(callback: (JsError?) -> Unit)
Link copied to clipboard
external fun _flush(callback: TransformCallback)
Link copied to clipboard
external fun _read(size: Number)
Link copied to clipboard
external fun _transform(chunk: Any?, enc: Any?, cb: Any?)
external fun _transform(chunk: Any?, encoding: BufferEncoding, callback: TransformCallback)
Link copied to clipboard
open external fun _write(chunk: Any?, encoding: BufferEncoding, callback: (JsError?) -> Unit)
Link copied to clipboard
external fun addListener(type: EventType, listener: EventListener)
open external override fun addListener(event: Symbol, listener: Function<Unit>)
open external override fun addListener(event: String, listener: Function<Unit>)
Link copied to clipboard
external fun asIndexedPairs(options: ArrayOptions): Readable
Link copied to clipboard
external fun <T : ReadableStream> compose(stream: T, options: StreamComposeOptions): T
external fun <T : ReadableStream> compose(stream: AsyncIterable<T>, options: StreamComposeOptions): T
external fun <T : ReadableStream> compose(stream: JsIterable<T>, options: StreamComposeOptions): T
external fun <T : ReadableStream> compose(stream: ComposeFnParam, options: StreamComposeOptions): T
Link copied to clipboard
open external fun cork()
Link copied to clipboard
open external override fun destroy()
open external override fun destroy(error: JsError)
Link copied to clipboard
external fun drop(limit: Number, options: ArrayOptions): Readable
Link copied to clipboard
external fun emit(type: EventType, vararg args: Any?): Boolean
open external override fun emit(event: Symbol, vararg args: Any?): Boolean
open external override fun emit(event: String, vararg args: Any?): Boolean
Link copied to clipboard
open external fun end(cb: () -> Unit)
open external fun end(data: Uint8Array<*>, cb: () -> Unit)
open external fun end(data: String, cb: () -> Unit)
open external fun end(str: String, encoding: BufferEncoding, cb: () -> Unit)
open external fun end(chunk: Any?, cb: () -> Unit)
open external fun end(chunk: Any?, encoding: BufferEncoding, cb: () -> Unit)
Link copied to clipboard
Link copied to clipboard
suspend external fun every(fn: (data: Any?, options: ArrayOptions?) -> PromiseResult<Boolean>, options: ArrayOptions): Boolean
Link copied to clipboard
external fun everyAsync(fn: (data: Any?, options: ArrayOptions?) -> PromiseResult<Boolean>, options: ArrayOptions): Promise<Boolean>
Link copied to clipboard
external fun filter(fn: (data: Any?, options: ArrayOptions?) -> PromiseResult<Boolean>, options: ArrayOptions): Readable
Link copied to clipboard
suspend external fun find(fn: (data: Any?, options: ArrayOptions?) -> PromiseResult<Boolean>, options: ArrayOptions): Any?
suspend external fun <T> find(fn: (data: Any?, options: ArrayOptions?) -> Boolean, options: ArrayOptions): T?
Link copied to clipboard
external fun findAsync(fn: (data: Any?, options: ArrayOptions?) -> PromiseResult<Boolean>, options: ArrayOptions): Promise<Any?>
external fun <T> findAsync(fn: (data: Any?, options: ArrayOptions?) -> Boolean, options: ArrayOptions): Promise<T?>
Link copied to clipboard
external fun flatMap(fn: (data: Any?, options: ArrayOptions?) -> Any?, options: ArrayOptions): Readable
Link copied to clipboard
suspend external fun forEach(fn: (data: Any?, options: ArrayOptions?) -> PromiseResult<Void>, options: ArrayOptions): Void
Link copied to clipboard
external fun forEachAsync(fn: (data: Any?, options: ArrayOptions?) -> PromiseResult<Void>, options: ArrayOptions): Promise<Void>
Link copied to clipboard
external fun getMaxListeners(): Double
Link copied to clipboard
open external fun isPaused(): Boolean
Link copied to clipboard
Link copied to clipboard
external fun listenerCount(type: EventType, listener: EventListener): Double
Link copied to clipboard
Link copied to clipboard
external fun map(fn: (data: Any?, options: ArrayOptions?) -> Any?, options: ArrayOptions): Readable
Link copied to clipboard
external fun off(type: EventType, listener: EventListener)
Link copied to clipboard
external fun on(type: EventType, listener: EventListener)
open external override fun on(event: Symbol, listener: Function<Unit>)
open external override fun on(event: String, listener: Function<Unit>)
Link copied to clipboard
external fun once(type: EventType, listener: EventListener)
open external override fun once(event: Symbol, listener: Function<Unit>)
open external override fun once(event: String, listener: Function<Unit>)
Link copied to clipboard
open external fun pause()
Link copied to clipboard
open external fun <T : WritableStream> pipe(destination: T, options: ReadableStreamPipeOptions): T
external fun <T : WritableStream> pipe(destination: T, options: StreamPipeOptions): T
Link copied to clipboard
external fun prependListener(type: EventType, listener: EventListener)
open external override fun prependListener(event: Symbol, listener: Function<Unit>)
open external override fun prependListener(event: String, listener: Function<Unit>)
Link copied to clipboard
external fun prependOnceListener(type: EventType, listener: EventListener)
open external override fun prependOnceListener(event: Symbol, listener: Function<Unit>)
open external override fun prependOnceListener(event: String, listener: Function<Unit>)
Link copied to clipboard
external fun push(chunk: Any?, encoding: BufferEncoding): Boolean
Link copied to clipboard
Link copied to clipboard
open external fun read(size: Number): Any
Link copied to clipboard
open external fun readOrNull(size: Number): Any?
Link copied to clipboard
suspend external fun <T> reduce(fn: (previous: T, data: Any?, options: ArrayOptions?) -> T, initial: T, options: ArrayOptions): T
suspend external fun <T> reduce(fn: (previous: Any?, data: Any?, options: ArrayOptions?) -> T, initial: Nothing?, options: ArrayOptions): T
Link copied to clipboard
external fun <T> reduceAsync(fn: (previous: T, data: Any?, options: ArrayOptions?) -> T, initial: T, options: ArrayOptions): Promise<T>
external fun <T> reduceAsync(fn: (previous: Any?, data: Any?, options: ArrayOptions?) -> T, initial: Nothing?, options: ArrayOptions): Promise<T>
Link copied to clipboard
external fun removeAllListeners(type: EventType)
Link copied to clipboard
external fun removeListener(type: EventType, listener: EventListener)
open external override fun removeListener(event: Symbol, listener: Function<Unit>)
open external override fun removeListener(event: String, listener: Function<Unit>)
Link copied to clipboard
open external fun resume()
Link copied to clipboard
open external fun setDefaultEncoding(encoding: BufferEncoding)
Link copied to clipboard
open external fun setEncoding(encoding: BufferEncoding)
Link copied to clipboard
external fun setMaxListeners(n: Number)
Link copied to clipboard
suspend external fun some(fn: (data: Any?, options: ArrayOptions?) -> PromiseResult<Boolean>, options: ArrayOptions): Boolean
Link copied to clipboard
external fun someAsync(fn: (data: Any?, options: ArrayOptions?) -> PromiseResult<Boolean>, options: ArrayOptions): Promise<Boolean>
Link copied to clipboard
external fun take(limit: Number, options: ArrayOptions): Readable
Link copied to clipboard
suspend external fun toArray(options: ArrayOptions): ReadonlyArray<Any?>
Link copied to clipboard
Link copied to clipboard
open external fun uncork()
Link copied to clipboard
open external fun unpipe(destination: WritableStream)
Link copied to clipboard
open external fun unshift(chunk: Uint8Array<*>, encoding: BufferEncoding)
open external fun unshift(chunk: String, encoding: BufferEncoding)
external fun unshift(chunk: Any?, encoding: BufferEncoding)
Link copied to clipboard
open external fun wrap(stream: ReadableStream)
Link copied to clipboard
open external fun write(buffer: Uint8Array<*>, cb: (JsError?) -> Unit): Boolean
open external fun write(buffer: String, cb: (JsError?) -> Unit): Boolean
open external fun write(str: String, encoding: BufferEncoding, cb: (JsError?) -> Unit): Boolean
open external fun write(chunk: Any?, callback: (JsError?) -> Unit): Boolean
open external fun write(chunk: Any?, encoding: BufferEncoding, callback: (JsError?) -> Unit): Boolean