src/streamlink/stream/segmented.py
def close(self):
        """Shuts down the thread."""
        if not self.closed:
            log.debug("Closing writer thread")

        self.closed = True
        self.reader.buffer.close()
        self.executor.shutdown(wait=False)
        if concurrent.futures.thread._threads_queues:
            concurrent.futures.thread._threads_queues.clear()
def close(self):
        """Shuts down the thread."""
        if not self.closed:
            log.debug("Closing writer thread")

        self.closed = True
        self.reader.buffer.close()
        self.executor.shutdown(wait=False)
        if concurrent.futures.thread._threads_queues:
            concurrent.futures.thread._threads_queues.clear()
def close ( self ) : if not self . closed : log . debug ( "Closing writer thread" ) self . closed = True self . reader . buffer . close ( ) self . executor . shutdown ( wait = False ) if concurrent . futures . thread . _threads_queues : concurrent . futures . thread . _threads_queues . clear ( )
Shuts down the thread.
Shuts down the thread .