func (r *PipelineManifestReader) NextCreatePipelineRequest() (*ppsclient.CreatePipelineRequest, error) {
	var result ppsclient.CreatePipelineRequest
	if err := jsonpb.UnmarshalNext(r.decoder, &result); err != nil {
		if err == io.EOF {
			return nil, err
		}
		return nil, fmt.Errorf("malformed pipeline spec: %s", err)
	}
	return &result, nil
}
func (r *PipelineManifestReader) NextCreatePipelineRequest() (*ppsclient.CreatePipelineRequest, error) {
	var result ppsclient.CreatePipelineRequest
	if err := jsonpb.UnmarshalNext(r.decoder, &result); err != nil {
		if err == io.EOF {
			return nil, err
		}
		return nil, fmt.Errorf("malformed pipeline spec: %s", err)
	}
	return &result, nil
}
func ( r * PipelineManifestReader ) NextCreatePipelineRequest ( ) ( * ppsclient . CreatePipelineRequest , error ) { var result ppsclient . CreatePipelineRequest if err := jsonpb . UnmarshalNext ( r . decoder , & result ) ; err != nil { if err == io . EOF { return nil , err } return nil , fmt . Errorf ( " " , err ) } return & result , nil }
// NextCreatePipelineRequest gets the next request from the manifest reader.
NextCreatePipelineRequest gets the next request from the manifest reader .