Create a new shared object; return the token and exposed tuple
(self, typeid, /, *args, **kwds)
| 602 | server.serve_forever() |
| 603 | |
| 604 | def _create(self, typeid, /, *args, **kwds): |
| 605 | ''' |
| 606 | Create a new shared object; return the token and exposed tuple |
| 607 | ''' |
| 608 | assert self._state.value == State.STARTED, 'server not yet started' |
| 609 | conn = self._Client(self._address, authkey=self._authkey) |
| 610 | try: |
| 611 | id, exposed = dispatch(conn, None, 'create', (typeid,)+args, kwds) |
| 612 | finally: |
| 613 | conn.close() |
| 614 | return Token(typeid, self._address, id), exposed |
| 615 | |
| 616 | def join(self, timeout=None): |
| 617 | ''' |