MCPcopy Index your code
hub / github.com/cameri/nostream / importFromReadable

Method importFromReadable

src/services/event-import-service.ts:148–153  ·  view source on GitHub ↗
(
    input: NodeJS.ReadableStream,
    options: EventImportOptions = {},
  )

Source from the content-addressed store, hash-verified

146 ) {}
147
148 public async importFromReadable(
149 input: NodeJS.ReadableStream,
150 options: EventImportOptions = {},
151 ): Promise<EventImportStats> {
152 return this.importFromCandidates(this.readJsonlCandidatesFromStream(input), options)
153 }
154
155 public async importFromJsonl(filePath: string, options: EventImportOptions = {}): Promise<EventImportStats> {
156 const stream = fs.createReadStream(filePath, {

Callers 3

runImportEventsFunction · 0.95
importFromJsonlMethod · 0.95

Calls 2

importFromCandidatesMethod · 0.95

Tested by

no test coverage detected