func PrintStream()

in pkg/docker.go [278:295]

• 18 lines of code
• 5 McCabe index (conditional complexity)

func PrintStream(ctx context.Context, stream io.ReadCloser) error {
	decoder := json.NewDecoder(stream)
	var s TextStream
	for {
		select {
		case <-ctx.Done():
			stream.Close()
			return nil
		default:
			if err := decoder.Decode(&s); err == io.EOF {
				return nil
			} else if err != nil {
				return err
			}
		}
		fmt.Print(s.Stream)
	}
}