Module ImportFrom alias ImportFrom alias alias ImportFrom alias ImportFrom alias ImportFrom alias ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam defaults body Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr Assign AttributeStore NameLoad attr AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str If UnaryOpNot AttributeLoad NameLoad attr body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str Assign AttributeStore NameLoad attr NameLoad If AttributeLoad NameLoad attr body Expr Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str Assign AttributeStore NameLoad attr Call NameLoad Return UnaryOpNot Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Return Expr Yield decorator_list FunctionDef arguments args NameParam defaults body For NameStore Call AttributeLoad NameLoad attr body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Expr Call AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam defaults Num NameLoad NameLoad NameLoad body Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr Assign AttributeStore NameLoad attr AttributeLoad NameLoad attr If UnaryOpNot NameLoad body Assign NameStore Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr Str If UnaryOpNot NameLoad body Assign NameStore Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr Str If UnaryOpNot NameLoad body Assign NameStore Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr Str Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr keyword NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str If UnaryOpNot AttributeLoad NameLoad attr body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str Assign AttributeStore NameLoad attr NameLoad Expr Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr keyword NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str If AttributeLoad NameLoad attr body Return If CompareIsNot NameLoad NameLoad body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr NameLoad keyword AttributeLoad NameLoad attr orelse Assign NameStore NameLoad Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr TupleLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str While UnaryOpNot AttributeLoad NameLoad attr body TryExcept body Expr Call AttributeLoad NameLoad attr NameLoad keyword NameLoad keyword Num Break handlers ExceptHandler type AttributeLoad NameLoad attr body Continue decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str Pass decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str Pass decorator_list FunctionDef arguments args NameParam defaults body While UnaryOpNot AttributeLoad NameLoad attr body TryExcept body Assign TupleStore NameStore NameStore Call AttributeLoad AttributeLoad NameLoad attr attr keyword NameLoad keyword Num handlers ExceptHandler type AttributeLoad NameLoad attr body Continue If CompareIs NameLoad NameLoad body Break While UnaryOpNot AttributeLoad NameLoad attr body TryExcept body Assign NameStore Call AttributeLoad NameLoad attr keyword Num handlers ExceptHandler type AttributeLoad NameLoad attr body Continue ExceptHandler type AttributeLoad NameLoad attr body Break If CompareIsNot NameLoad NameLoad body Expr Call AttributeLoad NameLoad attr NameLoad NameLoad Break Expr Call AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad body Assign NameStore NameLoad Assign NameStore NameLoad FunctionDef arguments args NameParam NameParam NameParam defaults NameLoad body Expr Call AttributeLoad NameLoad attr NameLoad Assign AttributeStore NameLoad attr AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr NameLoad If UnaryOpNot NameLoad body Assign NameStore Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr Str Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr Str Assign AttributeStore NameLoad attr Call NameLoad NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr For NameStore TupleLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr body If Call AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list FunctionDef arguments args NameParam NameParam defaults body If UnaryOpNot AttributeLoad NameLoad attr body Return Str Return Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad keyword Call AttributeLoad AttributeLoad NameLoad attr attr keyword AttributeLoad NameLoad attr decorator_list decorator_list
N/A concurrent futures threading Thread Event stream StreamIO buffers RingBuffer compat queue SegmentedStreamWorker N/A Thread N/A N/A The general worker thread.

    This thread is responsible for queueing up segments in the
    writer thread.
     __init__ N/A N/A self reader N/A N/A N/A N/A self closed False N/A N/A self reader reader N/A N/A self writer N/A reader writer N/A N/A self stream N/A reader stream N/A N/A self session N/A N/A reader stream session N/A N/A self logger N/A reader logger N/A N/A self _wait None N/A N/A N/A Thread __init__ self N/A N/A self daemon True N/A close N/A N/A self N/A N/A N/A Shuts down the thread. N/A N/A N/A self closed N/A N/A N/A N/A N/A self logger debug Closing worker thread N/A N/A self closed True N/A N/A self _wait N/A N/A N/A N/A N/A self _wait set N/A wait N/A N/A self time N/A N/A N/A Pauses the thread for a specified time.

        Returns False if interrupted by another thread and True if the
        time runs out normally.
         N/A N/A self _wait N/A Event N/A N/A N/A N/A N/A self _wait wait time N/A iter_segments N/A N/A self N/A N/A N/A The iterator that generates segments for the worker thread.

        Should be overridden by the inheriting class.
         N/A N/A N/A N/A run N/A N/A self N/A N/A N/A segment N/A N/A self iter_segments N/A N/A N/A N/A N/A self writer put segment N/A N/A N/A N/A self writer put None N/A N/A N/A self close N/A N/A SegmentedStreamWriter N/A Thread N/A N/A The writer thread.

    This thread is responsible for fetching segments, processing them
    and finally writing the data to the buffer.
     __init__ N/A N/A self reader size retries threads timeout N/A 20 None None None N/A N/A N/A self closed False N/A N/A self reader reader N/A N/A self stream N/A reader stream N/A N/A self session N/A N/A reader stream session N/A N/A self logger N/A reader logger N/A N/A retries N/A N/A retries N/A N/A N/A N/A self session options get stream-segment-attempts N/A N/A threads N/A N/A threads N/A N/A N/A N/A self session options get stream-segment-threads N/A N/A timeout N/A N/A timeout N/A N/A N/A N/A self session options get stream-segment-timeout N/A N/A self retries retries N/A N/A self timeout timeout N/A N/A self executor N/A N/A futures ThreadPoolExecutor max_workers threads N/A N/A self futures N/A N/A queue Queue size N/A N/A N/A Thread __init__ self N/A N/A self daemon True N/A close N/A N/A self N/A N/A N/A Shuts down the thread. N/A N/A N/A self closed N/A N/A N/A N/A N/A self logger debug Closing writer thread N/A N/A self closed True N/A N/A N/A N/A N/A self reader buffer close N/A N/A N/A N/A self executor shutdown wait True N/A put N/A N/A self segment N/A N/A N/A Adds a segment to the download pool and write queue. N/A N/A self closed N/A N/A N/A N/A segment None N/A N/A future N/A N/A N/A self executor submit N/A self fetch segment retries N/A self retries N/A N/A future None N/A N/A N/A self queue N/A self futures N/A segment future N/A queue N/A N/A self queue_ value N/A N/A N/A Puts a value into a queue but aborts if this thread is closed. N/A N/A N/A self closed N/A N/A N/A N/A N/A N/A queue_ put value block True timeout 1 N/A N/A N/A N/A N/A queue Full N/A N/A N/A fetch N/A N/A self segment N/A N/A N/A Fetches a segment.

        Should be overridden by the inheriting class.
         N/A N/A write N/A N/A self segment result N/A N/A N/A Writes a segment to the buffer.

        Should be overridden by the inheriting class.
         N/A N/A run N/A N/A self N/A N/A N/A N/A N/A self closed N/A N/A N/A N/A N/A segment future N/A N/A N/A self futures get block True timeout 0.5 N/A N/A N/A N/A queue Empty N/A N/A N/A N/A future None N/A N/A N/A N/A N/A self closed N/A N/A N/A N/A result N/A N/A future result timeout 0.5 N/A N/A N/A N/A futures TimeoutError N/A N/A N/A N/A N/A futures CancelledError N/A N/A N/A N/A result None N/A N/A N/A N/A self write segment result N/A N/A N/A N/A self close N/A N/A SegmentedStreamReader N/A StreamIO N/A N/A __worker__ SegmentedStreamWorker N/A __writer__ SegmentedStreamWriter __init__ N/A N/A self stream timeout N/A None N/A N/A N/A N/A StreamIO __init__ self N/A N/A self session N/A stream session N/A N/A self stream stream N/A N/A timeout N/A N/A timeout N/A N/A N/A N/A self session options get stream-timeout N/A N/A self timeout timeout N/A open N/A N/A self N/A N/A N/A buffer_size N/A N/A N/A self session get_option ringbuffer-size N/A N/A self buffer N/A RingBuffer buffer_size N/A N/A self writer N/A N/A self __writer__ self N/A N/A self worker N/A N/A self __worker__ self N/A N/A N/A N/A self writer start N/A N/A N/A N/A self worker start N/A close N/A N/A self N/A N/A N/A N/A N/A N/A self worker close N/A N/A N/A N/A self writer close N/A thread N/A N/A self worker N/A self writer N/A N/A N/A N/A thread is_alive N/A N/A N/A N/A thread join N/A N/A N/A N/A self buffer close N/A read N/A N/A self size N/A N/A N/A N/A N/A self buffer N/A N/A N/A N/A N/A N/A self buffer read size block N/A N/A N/A self writer is_alive timeout N/A self timeout N/A N/A