88from .queryable import Queryable , Query
99
1010def open (* args , ** kwargs ):
11- return Session (* args , ** kwargs )
11+ return Session (* args , ** kwargs )
1212
1313class Scout :
14- def __init__ (self , inner , receiver ):
15- self ._inner_ = inner
16- self .receiver = receiver
17-
18- def stop (self ):
19- self ._inner_ = None
14+ def __init__ (self , inner , receiver ):
15+ self ._inner_ = inner
16+ self .receiver = receiver
17+
18+ def stop (self ):
19+ self ._inner_ = None
2020
2121def scout (handler : IntoHandler [Hello , Any , Any ] = None , what : str = None , config : Config = None , timeout = None ):
22- from threading import Timer
23- if handler is None :
24- handler = ListCollector ()
25- handler = Handler (handler , lambda x : Hello ._upgrade_ )
26- scout = _scout (handler .closure , config , what )
27- scout = Scout (scout , handler .receiver )
28- if timeout :
29- Timer (timeout , lambda : scout .stop ()).start ()
30- return scout
22+ from threading import Timer
23+ if handler is None :
24+ handler = ListCollector ()
25+ handler = Handler (handler , lambda x : Hello ._upgrade_ )
26+ scout = _scout (handler .closure , config , what )
27+ scout = Scout (scout , handler .receiver )
28+ if timeout :
29+ Timer (timeout , lambda : scout .stop ()).start ()
30+ return scout
0 commit comments