def __init__(self, monitor, batch_size):
    self._monitor = monitor
    self._batch_size = batch_size
Closes all the sockets linked to this activity.
dataset/ETHPy150Open google/mysql-tools/drift_lib/drift_policies.py/FixedQuerySizePolicy.__init__--crossover with--dataset/ETHPy150Open osrg/ryu/ryu/services/protocols/bgp/base.py/Activity._close_asso_sockets