^hxSrSSKJr SrSSKJr SSKr"SS5r"SS \5r"S S \5r S r S r g)aeDecorators for running functions with context/sockets. .. versionadded:: 15.3 Like using Contexts and Sockets as context managers, but with decorator syntax. Context and sockets are closed at the end of the function. For example:: from zmq.decorators import context, socket @context() @socket(zmq.PUSH) def work(ctx, push): ... ) annotations)contextsocketwrapsNc4\rSrSrSrS SjrSrSrSrSr g) _Decorator!zThe mini decorator factoryNcXlgN_target)selftargets H/home/james-whalen/.local/lib/python3.13/site-packages/zmq/decorators.py__init___Decorator.__init__$s cL^^^^TR"T0TD6ummmUUUU4SjnU$)ab The main logic of decorator Here is how those arguments works:: @out_decorator(*dec_args, *dec_kwargs) def func(*wrap_args, **wrap_kwargs): ... And in the ``wrapper``, we simply create ``self.target`` instance via ``with``:: target = self.get_target(*args, **kwargs) with target(*dec_args, **dec_kwargs) as obj: ... c:>^[T5UUUUU4Sj5nU$)Nc>TR"U0UD6nU"T0TD6nT(a TU;aX1T'O-T(a!TU;a[TRSTS35eX4-nT"U0UD6sSSS5 $!,(df  g=f)Nz%() got multiple values for argument '') get_target TypeError__name__) argskwargsrobjdec_args dec_kwargsfunckw_namers rwrapper7_Decorator.__call__..decorator..wrapper>s$9&9X447*-w W%6'#}}o.**1!5 $f}00544s AA-- A;r)r!r#rr r"rs` r decorator&_Decorator.__call__..decorator=s% 4[ 1 1 1"Nr)process_decorator_args)rrr r%r"s``` @r__call___Decorator.__call__'s9$)-(C(C ) #) %:  *rcUR$)zGReturn the target function Allows modifying args/kwargs to be passed. r )rrrs rr_Decorator.get_targetTs ||rcSn[URS5[5(aURS5nO1[ U5S:a"[US[5(a USnUSSnX1U4$)zProcess args passed to the decorator. args not consumed by the decorator will be passed to the target factory (Context/Socket constructor). Nnamer) isinstancegetstrpoplen)rrrr"s rr'!_Decorator.process_decorator_args[sg  fjj(# . .jj(G Y!^ 47C 8 81gG8Df$$rr r ) r __module__ __qualname____firstlineno____doc__rr(rr'__static_attributes__rrr r !s$+Z%rr c,^\rSrSrSrU4SjrSrU=r$)_ContextDecoratorlzDecorator subclass for Contextsc@>[TU][R5 gr )superrzmqContext)r __class__s rr_ContextDecorator.__init__os %rr:)rr5r6r7r8rr9 __classcell__rBs@rr<r<ls)&&rr<c8^\rSrSrSrU4SjrSrSrSrU=r $)_SocketDecoratorszBDecorator subclass for sockets Gets the context from other args. c`>[TU]"U0UD6up1nURSS5UlX1U4$)z$Also grab context_name out of kwargs context_namer)r?r'r2rJ)rrrr"rBs rr''_SocketDecorator.process_decorator_argsys: % > O Ov"JJ~yAf$$rc>UR"U0UD6nUR$)z$Get context, based on call-time args) _get_contextr)rrrrs rr_SocketDecorator.get_targets!##T4V4~~rcURU;a/X Rn[U[R5(aU$UH&n[U[R5(dM$Us $ [RR 5$)ao Find the ``zmq.Context`` from ``args`` and ``kwargs`` at call time. First, if there is an keyword argument named ``context`` and it is a ``zmq.Context`` instance , we will take it. Second, we check all the ``args``, take the first ``zmq.Context`` instance. Finally, we will provide default Context -- ``zmq.Context.instance`` :return: a ``zmq.Context`` instance )rJr/r@rAinstance)rrrctxargs rrM_SocketDecorator._get_contextsk    &**+C#s{{++ C#s{{++ {{##%%r)rJ) rr5r6r7r8r'rrMr9rDrEs@rrGrGss %  &&rrGc"[5"U0UD6$)zDecorator for adding a Context to a function. Usage:: @context() def foo(ctx): ... .. versionadded:: 15.3 :param str name: the keyword argument passed to decorated function )r<rrs rrrs   / //rc"[5"U0UD6$)a/Decorator for adding a socket to a function. Usage:: @socket(zmq.PUSH) def foo(push): ... .. versionadded:: 15.3 :param str name: the keyword argument passed to decorated function :param str context_name: the keyword only argument to identify context object )rGrUs rrrs  t .v ..r) r8 __future__r__all__ functoolsrr@r r<rGrrr:rrrZsN"#    H%H%V& &)&z)&X 0 /r