Function readAll

plugins/destination/s3/client/client_test.go:139–152

(ctx context.Context, client plugin.Client, table *schema.Table)

}

func readAll(ctx context.Context, client plugin.Client, table *schema.Table) ([]arrow.RecordBatch, error) {
	var err error
	ch := make(chan arrow.RecordBatch)
	go func() {
		defer close(ch)
		err = client.Read(ctx, table, ch)
	}()
	// nolint:prealloc
	var records []arrow.RecordBatch
	for record := range ch {
		records = append(records, record)
	}
	return records, err
}