func (t *copyCatTransport) Step(stream pb.RaftTransportService_StepServer) error {
	for { //ever...
		request, err := stream.Recv()
		if err == io.EOF {
			return nil
		} else if err != nil {
			return err
		}

		err = t.membership.stepRaft(stream.Context(), *request.Message)
		if err != nil {
			err = fmt.Errorf("Invoking raft backend with id [%d] failed: %s", request.Message.To, err.Error())
			t.logger.Errorf("%s", err.Error())
			stream.Send(&pb.StepResp{Error: err.Error()})
		}

		stream.Send(&pb.StepResp{})
	}
}
//////////////////////////////////////////
////////////////////////////////
// SECTION FOR THE RAFT TRANSPORT
SECTION FOR THE RAFT TRANSPORT
////////////////////////////////////////// //////////////////////////////// // SECTION FOR THE RAFT TRANSPORT
func (t *copyCatTransport) Step(stream pb.RaftTransportService_StepServer) error {
	for { 
		request, err := stream.Recv()
		if err == io.EOF {
			return nil
		} else if err != nil {
			return err
		}
		err = t.membership.stepRaft(stream.Context(), *request.Message)
		if err != nil {
			err = fmt.Errorf("Invoking raft backend with id [%d] failed: %s", request.Message.To, err.Error())
			t.logger.Errorf("%s", err.Error())
			stream.Send(&pb.StepResp{Error: err.Error()})
		}
		stream.Send(&pb.StepResp{})
	}
}
func ( t * copyCatTransport ) Step ( stream pb . RaftTransportService_StepServer ) error { for { request , err := stream . Recv ( ) if err == io . EOF { return nil } else if err != nil { return err } err = t . membership . stepRaft ( stream . Context ( ) , * request . Message ) if err != nil { err = fmt . Errorf ( " " , request . Message . To , err . Error ( ) ) t . logger . Errorf ( " " , err . Error ( ) ) stream . Send ( & pb . StepResp { Error : err . Error ( ) } ) } stream . Send ( & pb . StepResp { } ) } }
SECTION FOR THE RAFT TRANSPORT
SECTION FOR THE RAFT TRANSPORT
//ever...