func()

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
	}
}