protected override PipelineStream PrepareStream()

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);
        }