(self, disconnectCallback=None, headers=None)
| 150 | self._transmit("CONNECT", headers) |
| 151 | |
| 152 | def disconnect(self, disconnectCallback=None, headers=None): |
| 153 | if headers is None: |
| 154 | headers = {} |
| 155 | |
| 156 | # self._transmit("DISCONNECT", headers) # comment this |
| 157 | self.ws.on_close = None |
| 158 | self.ws.close() |
| 159 | self._clean_up() |
| 160 | |
| 161 | if disconnectCallback is not None: |
| 162 | disconnectCallback() |
| 163 | |
| 164 | def _clean_up(self): |
| 165 | self.connected = False |
no test coverage detected