$logger.TransformWriter | /src/lib/$shared.ts | dxx@rf

Module

x/dxx/src/lib/$shared.ts>$logger.TransformWriter

🚀 (Deno) enhanced executor

rivy/deno.dxx

Latest

$fs

readableStreamFromReader

readAll

readerFromStreamReader

env

abortIfMissingPermits

callersFromStackTrace

env

mightUseFileSystemCase

mightUseUnicode

panicIfMissingPermits

consoleSizeViaDenoAPI

consoleSizeViaMode

consoleSizeViaPowerShell

wordSplitCLTextByShift

impairedWarningMessage

class $logger.TransformWriter

implements Writer<I>, Transformer<I, O>

import { $logger } from "https://deno.land/x/dxx@rf/src/lib/$shared.ts";
const { TransformWriter } = $logger;

Constructors

new

TransformWriter(fn?: TransformInContextFn<I, O>, options?: TransformWriterOptions<I, O>)

Type Parameters

optional

I = unknown

optional

O = I

Properties

readonly

_previewers: Writer[]

readonly

_transform: TransformInContextFn<I, O> | null | undefined

readonly

_writeQueue: PQueue

readonly

_writers: WriterDetail[]

readonly

id: string

Optional instance ID; may not be unique

Methods

chain<T>(t: TransformWriter<O, T>)

into(writer: Writer, options?)

onIdle()

Returns a promise which is fulfilled when all pending promised writes have settled. This function can assist in imposing a temporal partial ordering between writes with other code (async or sync).

```ts
// ... async or sync writes ...
x.write(...)
await x.write(...)
// ...
await x.onIdle(); // when settled, all enqueued/pending writes have been completed
// ...
```

previewInto(writer: Writer)

transform(i: I, ...inputs: I[])

write(chunk: I)

Static Methods

TransformWriterTransformFn<sI, _sO>(

_context: unknown | null,

_i: sI,

..._inputs: sI[],

)