U
vi @ s d dl mZmZ d dlmZmZmZ d dlmZ d dl m
Z
edZ edZ e
eddd Z
eeee e f gee e f f d
d d Zd
S ) )RLockThread)AnyCallableTypeVar) ParamSpec)StartableTarget_T_P)targetreturnc C s t | ddS )NT)r daemon)r )r r O/opt/alt/python38/lib/python3.8/site-packages/reactivex/internal/concurrency.pydefault_thread_factory s r )lockr c s( t ttf t ttf d fdd }|S )z9A decorator for synchronizing access to a given function.)fnr c s t jt jtd fdd }|S )N)argskwr c
s& | |W 5 Q R S Q R X d S )Nr )r r )r r r r inner s z,synchronized..wrapper..inner)r
r kwargsr )r r r )r r wrapper s z synchronized..wrapper)r r
r )r r r r r synchronized s $r N) threadingr r typingr r r Ztyping_extensionsr Zreactivex.typingr r r
r r r r r r s