"""CLI string to load the injected packets"""
if self._nb_replays is not None:
return "%s limit %d" % (self._input_cli, self._nb_replays)
"""CLI string to load the injected packets"""
if self._nb_replays is not None:
return "%s limit %d" % (self._input_cli, self._nb_replays)
- def add_stream(self, pkts, nb_replays=None):
+ def add_stream(self, pkts, nb_replays=None, worker=None):
self._nb_replays = nb_replays
self._rename_previous_capture_file(self.in_path,
self.in_history_counter,
self._nb_replays = nb_replays
self._rename_previous_capture_file(self.in_path,
self.in_history_counter,