Options
All
  • Public
  • Public/Protected
  • All
Menu

Class RowStream<T>

A row oriented stream.

Type parameters

  • T

Hierarchy

  • RowStream

Implements

  • any

Index

Methods

Methods

close

  • close(): PromiseLike<void>
  • close(completionHandler: ((res: AsyncResult<void>) => void) | Handler<AsyncResult<void>>): void

  • Close the stream and release the resources.

    Returns PromiseLike<void>

  • Close the stream and release the resources.

    Parameters

    • completionHandler: ((res: AsyncResult<void>) => void) | Handler<AsyncResult<void>>

    Returns void

endHandler

  • endHandler(endHandler: ((res: void) => void) | Handler<void> | null | undefined): RowStream<T>

  • Parameters

    • endHandler: ((res: void) => void) | Handler<void> | null | undefined

    Returns RowStream<T>

exceptionHandler

  • exceptionHandler(handler: ((res: Throwable) => void) | Handler<Throwable> | null | undefined): RowStream<T>

  • Parameters

    • handler: ((res: Throwable) => void) | Handler<Throwable> | null | undefined

    Returns RowStream<T>

fetch

  • Parameters

    • l: number

    Returns RowStream<T>

handler

  • handler(handler: ((res: T) => void) | Handler<T> | null | undefined): RowStream<T>

  • Parameters

    • handler: ((res: T) => void) | Handler<T> | null | undefined

    Returns RowStream<T>

pause

  • Returns RowStream<T>

pipe

  • pipe(): Pipe<T>

  • Returns Pipe<T>

pipeTo

  • pipeTo(dst: WriteStream<T>): PromiseLike<void>
  • pipeTo(dst: WriteStream<T>, handler: ((res: AsyncResult<void>) => void) | Handler<AsyncResult<void>>): void

  • Parameters

    • dst: WriteStream<T>

    Returns PromiseLike<void>

  • Parameters

    • dst: WriteStream<T>
    • handler: ((res: AsyncResult<void>) => void) | Handler<AsyncResult<void>>

    Returns void

resume

  • Returns RowStream<T>

Generated using TypeDoc