src/streamlink/stream/segmented.py
def put(self, segment):
        """Adds a segment to the download pool and write queue."""
        if self.closed:
            return

        if segment is not None:
            future = self.executor.submit(self.fetch, segment,
                                          retries=self.retries)
        else:
            future = None

        self.queue(self.futures, (segment, future))
def put(self, segment):
        if self.closed:
            return

        if segment is not None:
            future = self.executor.submit(self.fetch, segment,
                                          retries=self.retries)
        else:
            future = None

        self.queue(self.futures, (segment, future))
def put ( self , segment ) : if self . closed : return if segment is not None : future = self . executor . submit ( self . fetch , segment , retries = self . retries ) else : future = None self . queue ( self . futures , ( segment , future ) )
Adds a segment to the download pool and write queue.
Adds a segment to the download pool and write queue .