Class BufferedTokenStream

Implements

AsyncIterableIterator<TokenData>

Index

Constructors

Methods

[asyncIterator] close endInput flush next pushText

Constructors

constructor

new BufferedTokenStream(func, minTokenLength, minContextLength): BufferedTokenStream
Parameters
- func: TokenizeFunc
- minTokenLength: number
- minContextLength: number
Returns BufferedTokenStream
- Defined in agents/src/tokenize/token_stream.ts:23

Methods

[asyncIterator]

[asyncIterator](): BufferedTokenStream
Returns BufferedTokenStream
Implementation of AsyncIterableIterator.[asyncIterator]
- Defined in agents/src/tokenize/token_stream.ts:116

close

close(): void
Close both the input and output of the token stream

Returns void
- Defined in agents/src/tokenize/token_stream.ts:111

endInput

endInput(): void
Mark the input as ended and forbid additional pushes

Returns void
- Defined in agents/src/tokenize/token_stream.ts:98

flush

flush(): void
Flush the stream, causing it to process all pending text

Returns void
- Defined in agents/src/tokenize/token_stream.ts:69

next

next(): Promise<IteratorResult<TokenData, any>>
Returns Promise<IteratorResult<TokenData, any>>
Implementation of AsyncIterableIterator.next
- Defined in agents/src/tokenize/token_stream.ts:106

pushText

pushText(text): void
Push a string of text into the token stream
Parameters
- text: string
Returns void
- Defined in agents/src/tokenize/token_stream.ts:32