in api/datanode/standalone.go [33:45]
func (dnClient *DatanodeClient) StandaloneReceive() {
for {
proto, err := (*dnClient.standaloneClient).Recv()
if err == io.EOF {
return
}
if err != nil {
fmt.Println(err)
return
}
dnClient.standaloneReceiver <- *proto
}
}