in src/PSDocs/Pipeline/InvokePipeline.cs [82:121]
protected override PipelineStream PrepareStream()
{
if (!string.IsNullOrEmpty(Option.Input.ObjectPath))
{
AddVisitTargetObjectAction((targetObject, next) =>
{
return PipelineReceiverActions.ReadObjectPath(targetObject, next, Option.Input.ObjectPath, true);
});
}
if (Option.Input.Format == InputFormat.Yaml)
{
AddVisitTargetObjectAction((targetObject, next) =>
{
return PipelineReceiverActions.ConvertFromYaml(targetObject, next);
});
}
else if (Option.Input.Format == InputFormat.Json)
{
AddVisitTargetObjectAction((targetObject, next) =>
{
return PipelineReceiverActions.ConvertFromJson(targetObject, next);
});
}
else if (Option.Input.Format == InputFormat.PowerShellData)
{
AddVisitTargetObjectAction((targetObject, next) =>
{
return PipelineReceiverActions.ConvertFromPowerShellData(targetObject, next);
});
}
else if (Option.Input.Format == InputFormat.Detect && _InputPath != null)
{
AddVisitTargetObjectAction((targetObject, next) =>
{
return PipelineReceiverActions.DetectInputFormat(targetObject, next);
});
}
return new PipelineStream(VisitTargetObject, _InputPath);
}