func (r *QueryRunner) ReadWithContext(ctx context.Context, src io.Reader) error {
	ch := make(chan map[string]interface{}, 1000)

	g, ctx := errgroup.WithContext(ctx)
	g.Go(func() error {
		return r.readWorker(ch, src)
	})
	g.Go(func() error {
		return r.loadWorker(ch)
	})
	return g.Wait()
}
// ReadWithContext reads JSONL via io.Reader, creates table on in-memory SQLite and inserts records with context.
ReadWithContext reads JSONL via io.Reader, creates table on in-memory SQLite and inserts records with context.
// ReadWithContext reads JSONL via io . Reader creates table on in - memory SQLite and inserts records with context .
func (r *QueryRunner) ReadWithContext(ctx context.Context, src io.Reader) error {
	ch := make(chan map[string]interface{}, 1000)
	g, ctx := errgroup.WithContext(ctx)
	g.Go(func() error {
		return r.readWorker(ch, src)
	})
	g.Go(func() error {
		return r.loadWorker(ch)
	})
	return g.Wait()
}
func ( r * QueryRunner ) ReadWithContext ( ctx context . Context , src io . Reader ) error { ch := make ( chan map [ string ] interface { } , 1000 ) g , ctx := errgroup . WithContext ( ctx ) g . Go ( func ( ) error { return r . readWorker ( ch , src ) } ) g . Go ( func ( ) error { return r . loadWorker ( ch ) } ) return g . Wait ( ) }
ReadWithContext reads JSONL via io.Reader, creates table on in-memory SQLite and inserts records with context.
ReadWithContext reads JSONL via io . Reader creates table on in - memory SQLite and inserts records with context .