+
    O(i                     z    ^ RI t ^ RIHtHtHtHt  ! R R] P                  4      t ! R R] P                  4      tR# )    N)AnyCallableOptionalUnionc                   `   a  ] tR t^t o ]V 3R lR l4       tV 3R lR ltV 3R lR ltRtV t	R# )	AbstractContextc                    < V ^8  d   QhRS[ /#    returnint)format__classdict__s   "S/Users/agent/.openclaw/workspace/venv/lib/python3.14/site-packages/caio/abstract.py__annotate__AbstractContext.__annotate__   s     " "c "    c                    \         hNNotImplementedErrorselfs   &r   max_requestsAbstractContext.max_requests       !!r   c                    < V ^8  d   QhRS[ /# r
   r   )r   r   s   "r   r   r   
        2 2 2r   c                    \        V4      hr   r   r   aio_operationss   &*r   submitAbstractContext.submit
       !.11r   c                    < V ^8  d   QhRS[ /# r
   r   )r   r   s   "r   r   r      r   r   c                    \        V4      hr   r   r!   s   &*r   cancelAbstractContext.cancel   r%   r    N)
__name__
__module____qualname____firstlineno__propertyr   r#   r(   __static_attributes____classdictcell__r   s   @r   r   r      s+     " "2 22 2r   r   c                   `  a  ] tR t^t o ]]P                  RV 3R lR ll4       4       t]]P                  RV 3R lR ll4       4       t]]P                  RV 3R lR ll4       4       t	]]P                  RV 3R lR ll4       4       t
]P                  V 3R	 lR
 l4       t]]P                  V 3R lR l4       4       t]]P                  V 3R lR l4       4       t]]P                  V 3R lR l4       4       t]]P                  V 3R lR l4       4       t]P                  V 3R lR l4       tRtV tR# )AbstractOperationc                0   < V ^8  d   QhRS[ RS[ RS[ RR/# )r   nbytesfdoffsetr   r4   r   )r   r   s   "r   r   AbstractOperation.__annotate__   s/     " ""!"" 
"r   c                    \         h)z6
Creates a new instance of AIOOperation on read mode.
r   )clsr6   r7   r8   prioritys   &&&&&r   readAbstractOperation.read   
     "!r   c                0   < V ^8  d   QhRS[ RS[RS[RR/# )r   payload_bytesr7   r8   r   r4   )bytesr   )r   r   s   "r   r   r9      s/     " "!""" 
"r   c                    \         h)z7
Creates a new instance of AIOOperation on write mode.
r   )r;   rA   r7   r8   r<   s   &&&&&r   writeAbstractOperation.write   r?   r   c                $   < V ^8  d   QhRS[ RR/# r   r7   r   r4   r   )r   r   s   "r   r   r9   *   s     " "s "+> "r   c                    \         h)z7
Creates a new instance of AIOOperation on fsync mode.
r   r;   r7   r<   s   &&&r   fsyncAbstractOperation.fsync(   s
     "!r   c                $   < V ^8  d   QhRS[ RR/# rG   r   )r   r   s   "r   r   r9   2   s     " " ",? "r   c                    \         h)z8
Creates a new instance of AIOOperation on fdsync mode.
r   rI   s   &&&r   fdsyncAbstractOperation.fdsync0   s
     "!r   c                6   < V ^8  d   QhRS[ S[S[3,          /# r
   )r   rB   r   )r   r   s   "r   r   r9   :   s     " "5, "r   c                    \         h)z@
Method returns a bytes value of AIOOperation's result or None.
r   r   s   &r   	get_valueAbstractOperation.get_value9   s
    
 "!r   c                    < V ^8  d   QhRS[ /# r
   r   )r   r   s   "r   r   r9   B        " " "r   c                    \         hr   r   r   s   &r   filenoAbstractOperation.fileno@   
     "!r   c                    < V ^8  d   QhRS[ /# r
   r   )r   r   s   "r   r   r9   G   rU   r   c                    \         hr   r   r   s   &r   r8   AbstractOperation.offsetE   rY   r   c                F   < V ^8  d   QhRS[ S[S[S[3,          ,          /# r
   )r   r   rB   
memoryview)r   r   s   "r   r   r9   L   s#     " "%z(9":; "r   c                    \         hr   r   r   s   &r   payloadAbstractOperation.payloadJ   rY   r   c                    < V ^8  d   QhRS[ /# r
   r   )r   r   s   "r   r   r9   Q   rU   r   c                    \         hr   r   r   s   &r   r6   AbstractOperation.nbytesO   rY   r   c                >   < V ^8  d   QhRS[ S[.S[3,          RS[/# )r   callbackr   )r   r   r   bool)r   r   s   "r   r   r9   U   s&     " "XseSj%9 "d "r   c                    \         hr   r   )r   rf   s   &&r   set_callbackAbstractOperation.set_callbackT   r   r   r*   N)r   )r+   r,   r-   r.   classmethodabcabstractmethodr=   rD   rJ   rN   rR   r/   rW   r8   r`   r6   ri   r0   r1   r2   s   @r   r4   r4      s[    " "  " " "  " " "  " " "  " 	" " "  " "  " "  " "  " 	" "r   r4   )	rl   typingr   r   r   r   ABCr   r4   r*   r   r   <module>rp      s0    
 1 1	2cgg 	2E" E"r   