Called once by Cluster.connect(). This should be used by implementations to set up any resources that will be shared across connections.
(cls)
| 828 | |
| 829 | @classmethod |
| 830 | def initialize_reactor(cls): |
| 831 | """ |
| 832 | Called once by Cluster.connect(). This should be used by implementations |
| 833 | to set up any resources that will be shared across connections. |
| 834 | """ |
| 835 | pass |
| 836 | |
| 837 | @classmethod |
| 838 | def handle_fork(cls): |
no outgoing calls