// NewWorkflowDetector Create a new log processor that detects workflows declared in lines
NewWorkflowDetector Create a new log processor that detects workflows declared in lines
// NewWorkflowDetector Create a new log processor that detects workflows declared in lines
func NewWorkflowDetector(reader io.ReadCloser, receiver func(string)) io.ReadCloser {
	lineReceiver := func([]byte) {}
	lineLimit := func() int { return maxWorkflowDeclarationLineSize }
	if receiver != nil {
		detector := &workflowDetector{
			receiver: receiver,
		}
		lineReceiver = detector.receive
		lineLimit = detector.limit
	}
	lineBuffer := buffer.NewLineBuffer(lineReceiver, lineLimit)
	return coreio.TeeReadCloser(reader, lineBuffer)
}
func NewWorkflowDetector ( reader io . ReadCloser , receiver func ( string ) ) io . ReadCloser { lineReceiver := func ( [ ] byte ) { } lineLimit := func ( ) int { return maxWorkflowDeclarationLineSize } if receiver != nil { detector := & workflowDetector { receiver : receiver , } lineReceiver = detector . receive lineLimit = detector . limit } lineBuffer := buffer . NewLineBuffer ( lineReceiver , lineLimit ) return coreio . TeeReadCloser ( reader , lineBuffer ) }
NewWorkflowDetector Create a new log processor that detects workflows declared in lines
NewWorkflowDetector Create a new log processor that detects workflows declared in lines