Method processObjects

command/cat.go:131–149

(ctx context.Context, client *storage.S3, objectChan <-chan *storage.Object)

}

func (c Cat) processObjects(ctx context.Context, client *storage.S3, objectChan <-chan *storage.Object) error {
	for obj := range objectChan {
		if obj.Err != nil {
			printError(c.fullCommand, c.op, obj.Err)
			return obj.Err
		}

		if obj.Type.IsDir() {
			continue
		}

		err := c.processSingleObject(ctx, client, obj.URL)
		if err != nil {
			printError(c.fullCommand, c.op, err)
			return err
		}
	}
	return nil
}

func (c Cat) processSingleObject(ctx context.Context, client *storage.S3, url *url.URL) error {
	buf := orderedwriter.New(os.Stdout)