Method Create

internal/vm/task_test.go:53–59

(_ context.Context, req *taskAPI.CreateTaskRequest)

}

func (s *mockTaskService) Create(_ context.Context, req *taskAPI.CreateTaskRequest) (*taskAPI.CreateTaskResponse, error) {
	reqCh, _ := s.createRequests.LoadOrStore(req.ID, make(chan *taskAPI.CreateTaskRequest, 128))
	reqCh.(chan *taskAPI.CreateTaskRequest) <- req
	return &taskAPI.CreateTaskResponse{
		Pid: 123,
	}, nil
}

func (s *mockTaskService) PopCreateRequests(id string) (reqs []*taskAPI.CreateTaskRequest) {
	reqCh, _ := s.createRequests.Load(id)