@@ -17,12 +17,13 @@ LoggerPipelineStage() = LoggerPipelineStage(Core.stdout, "Log")
1717LoggerPipelineStage (output:: IO ) = LoggerPipelineStage (output, " Log" )
1818LoggerPipelineStage (prefix:: String ) = LoggerPipelineStage (Core. stdout , prefix)
1919
20- Base. println (stage:: LoggerPipelineStage , something) = Base. println (stage, stage. output, append_prefix (stage, something))
20+ logger_pipeline_stage_println (logger:: LoggerPipelineStage , something:: Any ) =
21+ logger_pipeline_stage_println (logger, logger. output, logger_pipeline_stage_append_prefix (logger, something))
2122
22- Base . println (stage :: LoggerPipelineStage , output:: Core.CoreSTDOUT , something) = Core. println (output, something)
23- Base . println (stage :: LoggerPipelineStage , output, something) = println (output, something)
23+ logger_pipeline_stage_println (logger :: LoggerPipelineStage , output:: Core.CoreSTDOUT , something) = Core. println (output, something)
24+ logger_pipeline_stage_println (logger :: LoggerPipelineStage , output, something) = println (output, something)
2425
25- append_prefix (stage :: LoggerPipelineStage , something) = string ( " [ " , stage . prefix, " ] " , something)
26+ logger_pipeline_stage_append_prefix (logger :: LoggerPipelineStage , something) = lazy " [$(logger .prefix)]$ something"
2627
27- apply_pipeline_stage (stage :: LoggerPipelineStage , factornode, tag:: Val{T} , stream) where {T} = stream |> tap ((v) -> println (stage, " [$(functionalform (factornode)) ][$(T) ]: $v " ))
28- apply_pipeline_stage (stage :: LoggerPipelineStage , factornode, tag:: Tuple{Val{T}, Int} , stream) where {T} = stream |> tap ((v) -> println (stage, " [$(functionalform (factornode)) ][$(T) :$(tag[2 ]) ]: $v " ))
28+ apply_pipeline_stage (logger :: LoggerPipelineStage , factornode, tag:: Val{T} , stream) where {T} = stream |> tap ((v) -> logger_pipeline_stage_println (logger, lazy " [$(functionalform(factornode))][$(T)]: $v" ))
29+ apply_pipeline_stage (logger :: LoggerPipelineStage , factornode, tag:: Tuple{Val{T}, Int} , stream) where {T} = stream |> tap ((v) -> logger_pipeline_stage_println (logger, lazy " [$(functionalform(factornode))][$(T):$(tag[2])]: $v" ))
0 commit comments