|
return func(args []string, in beam.Receiver, out beam.Sender) {
|
|
return func(args []string, in beam.Receiver, out beam.Sender) {
|
|
stdout, err := beam.SendPipe(out, data.Empty().Set("cmd", "log", "stdout").Set("fromcmd", args...).Bytes())
|
|
stdout, err := beam.SendPipe(out, data.Empty().Set("cmd", "log", "stdout").Set("fromcmd", args...).Bytes())
|