Method Wait

internal/vm/task_test.go:125–138

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

}

func (s *mockTaskService) Wait(_ context.Context, req *taskAPI.WaitRequest) (*taskAPI.WaitResponse, error) {
	reqCh, _ := s.waitRequests.LoadOrStore(req.ID, make(chan *taskAPI.WaitRequest, 128))
	reqCh.(chan *taskAPI.WaitRequest) <- req

	waitCh, _ := s.waitCh.Load(s.processID(req.ID, req.ExecID))
	if waitCh != nil {
		<-(waitCh.(chan struct{}))
	}

	return &taskAPI.WaitResponse{
		ExitStatus: 0,
		ExitedAt:   protobuf.ToTimestamp(time.Now()),
	}, nil
}

func (s *mockTaskService) PopWaitRequests(id string) (reqs []*taskAPI.WaitRequest) {
	reqCh, _ := s.waitRequests.Load(id)