Method
_enter
(self, eta, priority, entry, **kwargs)
Source from the content-addressed store, hash-verified
| 46 | self._queue = set() |
| 47 | |
| 48 | def _enter(self, eta, priority, entry, **kwargs): |
| 49 | secs = max(eta - monotonic(), 0) |
| 50 | g = self._spawn_after(secs, entry) |
| 51 | self._queue.add(g) |
| 52 | g.link(self._entry_exit, entry) |
| 53 | g.entry = entry |
| 54 | g.eta = eta |
| 55 | g.priority = priority |
| 56 | g.canceled = False |
| 57 | return g |
| 58 | |
| 59 | def _entry_exit(self, g, entry): |
| 60 | try: |
Callers
nothing calls this directly
Tested by
no test coverage detected