func New(name string, bufferLength int) *UnaryOperator {
	// extract logger
	o := new(UnaryOperator)

	o.concurrency = 1
	o.input = make(chan interface{}, bufferLength)
	o.outputs = make(map[string]chan<- interface{})
	o.name = name
	return o
}
// NewUnary creates *UnaryOperator value
NewUnary creates *UnaryOperator value
// NewUnary creates * UnaryOperator value
func New(name string, bufferLength int) *UnaryOperator {
	o := new(UnaryOperator)
	o.concurrency = 1
	o.input = make(chan interface{}, bufferLength)
	o.outputs = make(map[string]chan<- interface{})
	o.name = name
	return o
}
func New ( name string , bufferLength int ) * UnaryOperator { o := new ( UnaryOperator ) o . concurrency = 1 o . input = make ( chan interface { } , bufferLength ) o . outputs = make ( map [ string ] chan <- interface { } ) o . name = name return o }
NewUnary creates *UnaryOperator value
NewUnary creates * UnaryOperator value
// extract logger