Function Display

internal/jsonstream/display.go:50–69

Display prints the JSON messages from the given reader to the given stream. It wraps the [jsonmessage.DisplayJSONMessagesStream] function to make it "context aware" and appropriately returns why the function was canceled. It returns an error if the context is canceled, but not if the input reader

(ctx context.Context, in io.Reader, stream *streams.Out, opts ...Options)

//
// It returns an error if the context is canceled, but not if the input reader / stream is closed.
func Display(ctx context.Context, in io.Reader, stream *streams.Out, opts ...Options) error {
	if ctx.Err() != nil {
		return ctx.Err()
	}

	reader := &ctxReader{err: make(chan error, 1), r: in}
	stopFunc := context.AfterFunc(ctx, func() { reader.err <- ctx.Err() })
	defer stopFunc()

	o := options{}
	for _, opt := range opts {
		opt(&o)
	}

	if err := jsonmessage.DisplayJSONMessagesStream(reader, stream, stream.FD(), stream.IsTerminal(), o.AuxCallback); err != nil {
		return err
	}

	return ctx.Err()
}