Commit fe0a659
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -740,6 +740,12 @@ def _keepalive_account_socket(self, socket_type): | |||
| 740 | 740 | if listen_key != self._listen_keys[socket_type]: | |
| 741 | 741 | self._start_account_socket(socket_type, listen_key, callback) | |
| 742 | 742 | else: | |
| 743 | + if socket_type == 'user': | ||
| 744 | + self._client.stream_keepalive(listen_key) | ||
| 745 | + elif socket_type == 'margin': # cross-margin | ||
| 746 | + self._client.margin_stream_keepalive(listen_key) | ||
| 747 | + else: # isolated margin | ||
| 748 | + self._client.isolated_margin_stream_keepalive(listen_key) | ||
| 743 | 749 | self._start_socket_timer(socket_type) | |
| 744 | 750 | ||
| 745 | 751 | def stop_socket(self, conn_key): | |
0 commit comments