grpc-brain-1_13.go

func (s *theSocialRobotServer) EventStream(stream pb.TheSocialRobot_EventStreamServer) error {
    for {
    // TODO handle events from the client
        _, err := stream.Recv()
        if err == io.EOF {
            return nil
        }
        if err != nil {
            return err
        }

        log.Printf("Received event, sending one command")
        // respond with a single command
        // TODO eventually we'll decouple receiving events from sending commands
        command := &pb.BodyCommand{
           Id:      1,
           Actions: {% raw %} []*pb.Action{{Delay: 0, Action: &pb.Action_Say{Say: &pb.Say{Text: "Hello World"}}}}, {% endraw %}
        }
        stream.Send(command)
    }
}