Startsida Utforska Hjälp
Logga in
carto
/
grpc
2
0
Fork 0
Filer Ärenden 0 Pull-förfrågningar 0 Wiki
Träd: 3f66501c9c
Grenar Taggar
grpc
/
python
/
_modules
/
grpc
/
experimental
/
aio
/
_channel.html

_channel.html 71 KB
Historik Rå

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593 
  1. 

  2. <!DOCTYPE html>
    3. 

  3. 

  4. <html lang="en">
    5. 

  5.   <head>
    6. 

  6.     <meta charset="utf-8" />
    7. 

  7.     <meta name="viewport" content="width=device-width, initial-scale=1.0">
    8. 

  8.     <title>grpc.experimental.aio._channel &#8212; gRPC Python 1.31.0 documentation</title>
    9. 

  9.     <link rel="stylesheet" href="../../../../_static/alabaster.css" type="text/css" />
    10. 

  10.     <link rel="stylesheet" href="../../../../_static/pygments.css" type="text/css" />
    11. 

  11.     <script id="documentation_options" data-url_root="../../../../" src="../../../../_static/documentation_options.js"></script>
    12. 

  12.     <script src="../../../../_static/jquery.js"></script>
    13. 

  13.     <script src="../../../../_static/underscore.js"></script>
    14. 

  14.     <script src="../../../../_static/doctools.js"></script>
    15. 

  15.     <script src="../../../../_static/language_data.js"></script>
    16. 

  16.     <link rel="index" title="Index" href="../../../../genindex.html" />
    17. 

  17.     <link rel="search" title="Search" href="../../../../search.html" />
    18. 

  18.    
    19. 

  19.   <link rel="stylesheet" href="../../../../_static/custom.css" type="text/css" />
    20. 

  20.   
    21. 

  21.   
    22. 

  22.   <meta name="viewport" content="width=device-width, initial-scale=0.9, maximum-scale=0.9" />
    23. 

  23. 

  24.   </head><body>
    25. 

  25.   <div class="document">
    26. 

  26.     
    27. 

  27.       <div class="sphinxsidebar" role="navigation" aria-label="main navigation">
    28. 

  28.         <div class="sphinxsidebarwrapper">
    29. 

  29. <h1 class="logo"><a href="../../../../index.html">gRPC Python</a></h1>
    30. 

  30. 

  31. 

  32. 

  33. <p class="blurb">1.31.0</p>
    34. 

  34. 

  35. 

  36. 

  37. 

  38. 

  39. 

  40. <h3>Navigation</h3>
    41. 

  41. <p class="caption"><span class="caption-text">Contents:</span></p>
    42. 

  42. <ul>
    43. 

  43. <li class="toctree-l1"><a class="reference internal" href="../../../../grpc.html">gRPC</a></li>
    44. 

  44. <li class="toctree-l1"><a class="reference internal" href="../../../../grpc_asyncio.html">gRPC AsyncIO API</a></li>
    45. 

  45. <li class="toctree-l1"><a class="reference internal" href="../../../../grpc_channelz.html">gRPC Channelz</a></li>
    46. 

  46. <li class="toctree-l1"><a class="reference internal" href="../../../../grpc_health_checking.html">gRPC Health Checking</a></li>
    47. 

  47. <li class="toctree-l1"><a class="reference internal" href="../../../../grpc_reflection.html">gRPC Reflection</a></li>
    48. 

  48. <li class="toctree-l1"><a class="reference internal" href="../../../../grpc_status.html">gRPC Status</a></li>
    49. 

  49. <li class="toctree-l1"><a class="reference internal" href="../../../../grpc_testing.html">gRPC Testing</a></li>
    50. 

  50. <li class="toctree-l1"><a class="reference internal" href="../../../../glossary.html">Glossary</a></li>
    51. 

  51. </ul>
    52. 

  52. 

  53. <div class="relations">
    54. 

  54. <h3>Related Topics</h3>
    55. 

  55. <ul>
    56. 

  56.   <li><a href="../../../../index.html">Documentation overview</a><ul>
    57. 

  57.   <li><a href="../../../index.html">Module code</a><ul>
    58. 

  58.   <li><a href="../../../grpc.html">grpc</a><ul>
    59. 

  59.   </ul></li>
    60. 

  60.   </ul></li>
    61. 

  61.   </ul></li>
    62. 

  62. </ul>
    63. 

  63. </div>
    64. 

  64. <div id="searchbox" style="display: none" role="search">
    65. 

  65.   <h3 id="searchlabel">Quick search</h3>
    66. 

  66.     <div class="searchformwrapper">
    67. 

  67.     <form class="search" action="../../../../search.html" method="get">
    68. 

  68.       <input type="text" name="q" aria-labelledby="searchlabel" />
    69. 

  69.       <input type="submit" value="Go" />
    70. 

  70.     </form>
    71. 

  71.     </div>
    72. 

  72. </div>
    73. 

  73. <script>$('#searchbox').show(0);</script>
    74. 

  74. 

  75. 

  76. 

  77. 

  78. 

  79. 

  80. 

  81. 

  82.         </div>
    83. 

  83.       </div>
    84. 

  84.       <div class="documentwrapper">
    85. 

  85.         <div class="bodywrapper">
    86. 

  86.           
    87. 

  87. 

  88.           <div class="body" role="main">
    89. 

  89.             
    90. 

  90.   <h1>Source code for grpc.experimental.aio._channel</h1><div class="highlight"><pre>
    91. 

  91. <span></span><span class="c1"># Copyright 2019 gRPC authors.</span>
    92. 

  92. <span class="c1">#</span>
    93. 

  93. <span class="c1"># Licensed under the Apache License, Version 2.0 (the &quot;License&quot;);</span>
    94. 

  94. <span class="c1"># you may not use this file except in compliance with the License.</span>
    95. 

  95. <span class="c1"># You may obtain a copy of the License at</span>
    96. 

  96. <span class="c1">#</span>
    97. 

  97. <span class="c1">#     http://www.apache.org/licenses/LICENSE-2.0</span>
    98. 

  98. <span class="c1">#</span>
    99. 

  99. <span class="c1"># Unless required by applicable law or agreed to in writing, software</span>
    100. 

  100. <span class="c1"># distributed under the License is distributed on an &quot;AS IS&quot; BASIS,</span>
    101. 

  101. <span class="c1"># WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.</span>
    102. 

  102. <span class="c1"># See the License for the specific language governing permissions and</span>
    103. 

  103. <span class="c1"># limitations under the License.</span>
    104. 

  104. <span class="sd">&quot;&quot;&quot;Invocation-side implementation of gRPC Asyncio Python.&quot;&quot;&quot;</span>
    105. 

  105. 

  106. <span class="kn">import</span> <span class="nn">asyncio</span>
    107. 

  107. <span class="kn">import</span> <span class="nn">sys</span>
    108. 

  108. <span class="kn">from</span> <span class="nn">typing</span> <span class="kn">import</span> <span class="n">Any</span><span class="p">,</span> <span class="n">Iterable</span><span class="p">,</span> <span class="n">Optional</span><span class="p">,</span> <span class="n">Sequence</span><span class="p">,</span> <span class="n">List</span>
    109. 

  109. 

  110. <span class="kn">import</span> <span class="nn">grpc</span>
    111. 

  111. <span class="kn">from</span> <span class="nn">grpc</span> <span class="kn">import</span> <span class="n">_common</span><span class="p">,</span> <span class="n">_compression</span><span class="p">,</span> <span class="n">_grpcio_metadata</span>
    112. 

  112. <span class="kn">from</span> <span class="nn">grpc._cython</span> <span class="kn">import</span> <span class="n">cygrpc</span>
    113. 

  113. 

  114. <span class="kn">from</span> <span class="nn">.</span> <span class="kn">import</span> <span class="n">_base_call</span><span class="p">,</span> <span class="n">_base_channel</span>
    115. 

  115. <span class="kn">from</span> <span class="nn">._call</span> <span class="kn">import</span> <span class="p">(</span><span class="n">StreamStreamCall</span><span class="p">,</span> <span class="n">StreamUnaryCall</span><span class="p">,</span> <span class="n">UnaryStreamCall</span><span class="p">,</span>
    116. 

  116.                     <span class="n">UnaryUnaryCall</span><span class="p">)</span>
    117. 

  117. <span class="kn">from</span> <span class="nn">._interceptor</span> <span class="kn">import</span> <span class="p">(</span>
    118. 

  118.     <span class="n">InterceptedUnaryUnaryCall</span><span class="p">,</span> <span class="n">InterceptedUnaryStreamCall</span><span class="p">,</span>
    119. 

  119.     <span class="n">InterceptedStreamUnaryCall</span><span class="p">,</span> <span class="n">InterceptedStreamStreamCall</span><span class="p">,</span> <span class="n">ClientInterceptor</span><span class="p">,</span>
    120. 

  120.     <span class="n">UnaryUnaryClientInterceptor</span><span class="p">,</span> <span class="n">UnaryStreamClientInterceptor</span><span class="p">,</span>
    121. 

  121.     <span class="n">StreamUnaryClientInterceptor</span><span class="p">,</span> <span class="n">StreamStreamClientInterceptor</span><span class="p">)</span>
    122. 

  122. <span class="kn">from</span> <span class="nn">._metadata</span> <span class="kn">import</span> <span class="n">Metadata</span>
    123. 

  123. <span class="kn">from</span> <span class="nn">._typing</span> <span class="kn">import</span> <span class="p">(</span><span class="n">ChannelArgumentType</span><span class="p">,</span> <span class="n">DeserializingFunction</span><span class="p">,</span>
    124. 

  124.                       <span class="n">SerializingFunction</span><span class="p">,</span> <span class="n">RequestIterableType</span><span class="p">)</span>
    125. 

  125. <span class="kn">from</span> <span class="nn">._utils</span> <span class="kn">import</span> <span class="n">_timeout_to_deadline</span>
    126. 

  126. 

  127. <span class="n">_USER_AGENT</span> <span class="o">=</span> <span class="s1">&#39;grpc-python-asyncio/</span><span class="si">{}</span><span class="s1">&#39;</span><span class="o">.</span><span class="n">format</span><span class="p">(</span><span class="n">_grpcio_metadata</span><span class="o">.</span><span class="n">__version__</span><span class="p">)</span>
    128. 

  128. 

  129. <span class="k">if</span> <span class="n">sys</span><span class="o">.</span><span class="n">version_info</span><span class="p">[</span><span class="mi">1</span><span class="p">]</span> <span class="o">&lt;</span> <span class="mi">7</span><span class="p">:</span>
    130. 

  130. 

  131.     <span class="k">def</span> <span class="nf">_all_tasks</span><span class="p">()</span> <span class="o">-&gt;</span> <span class="n">Iterable</span><span class="p">[</span><span class="n">asyncio</span><span class="o">.</span><span class="n">Task</span><span class="p">]:</span>
    132. 

  132.         <span class="k">return</span> <span class="n">asyncio</span><span class="o">.</span><span class="n">Task</span><span class="o">.</span><span class="n">all_tasks</span><span class="p">()</span>
    133. 

  133. <span class="k">else</span><span class="p">:</span>
    134. 

  134. 

  135.     <span class="k">def</span> <span class="nf">_all_tasks</span><span class="p">()</span> <span class="o">-&gt;</span> <span class="n">Iterable</span><span class="p">[</span><span class="n">asyncio</span><span class="o">.</span><span class="n">Task</span><span class="p">]:</span>
    136. 

  136.         <span class="k">return</span> <span class="n">asyncio</span><span class="o">.</span><span class="n">all_tasks</span><span class="p">()</span>
    137. 

  137. 

  138. 

  139. <span class="k">def</span> <span class="nf">_augment_channel_arguments</span><span class="p">(</span><span class="n">base_options</span><span class="p">:</span> <span class="n">ChannelArgumentType</span><span class="p">,</span>
    140. 

  140.                                <span class="n">compression</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="n">grpc</span><span class="o">.</span><span class="n">Compression</span><span class="p">]):</span>
    141. 

  141.     <span class="n">compression_channel_argument</span> <span class="o">=</span> <span class="n">_compression</span><span class="o">.</span><span class="n">create_channel_option</span><span class="p">(</span>
    142. 

  142.         <span class="n">compression</span><span class="p">)</span>
    143. 

  143.     <span class="n">user_agent_channel_argument</span> <span class="o">=</span> <span class="p">((</span>
    144. 

  144.         <span class="n">cygrpc</span><span class="o">.</span><span class="n">ChannelArgKey</span><span class="o">.</span><span class="n">primary_user_agent_string</span><span class="p">,</span>
    145. 

  145.         <span class="n">_USER_AGENT</span><span class="p">,</span>
    146. 

  146.     <span class="p">),)</span>
    147. 

  147.     <span class="k">return</span> <span class="nb">tuple</span><span class="p">(</span><span class="n">base_options</span>
    148. 

  148.                 <span class="p">)</span> <span class="o">+</span> <span class="n">compression_channel_argument</span> <span class="o">+</span> <span class="n">user_agent_channel_argument</span>
    149. 

  149. 

  150. 

  151. <span class="k">class</span> <span class="nc">_BaseMultiCallable</span><span class="p">:</span>
    152. 

  152.     <span class="sd">&quot;&quot;&quot;Base class of all multi callable objects.</span>
    153. 

  153. 

  154. <span class="sd">    Handles the initialization logic and stores common attributes.</span>
    155. 

  155. <span class="sd">    &quot;&quot;&quot;</span>
    156. 

  156.     <span class="n">_loop</span><span class="p">:</span> <span class="n">asyncio</span><span class="o">.</span><span class="n">AbstractEventLoop</span>
    157. 

  157.     <span class="n">_channel</span><span class="p">:</span> <span class="n">cygrpc</span><span class="o">.</span><span class="n">AioChannel</span>
    158. 

  158.     <span class="n">_method</span><span class="p">:</span> <span class="nb">bytes</span>
    159. 

  159.     <span class="n">_request_serializer</span><span class="p">:</span> <span class="n">SerializingFunction</span>
    160. 

  160.     <span class="n">_response_deserializer</span><span class="p">:</span> <span class="n">DeserializingFunction</span>
    161. 

  161.     <span class="n">_interceptors</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="n">Sequence</span><span class="p">[</span><span class="n">ClientInterceptor</span><span class="p">]]</span>
    162. 

  162.     <span class="n">_loop</span><span class="p">:</span> <span class="n">asyncio</span><span class="o">.</span><span class="n">AbstractEventLoop</span>
    163. 

  163. 

  164.     <span class="c1"># pylint: disable=too-many-arguments</span>
    165. 

  165.     <span class="k">def</span> <span class="fm">__init__</span><span class="p">(</span>
    166. 

  166.             <span class="bp">self</span><span class="p">,</span>
    167. 

  167.             <span class="n">channel</span><span class="p">:</span> <span class="n">cygrpc</span><span class="o">.</span><span class="n">AioChannel</span><span class="p">,</span>
    168. 

  168.             <span class="n">method</span><span class="p">:</span> <span class="nb">bytes</span><span class="p">,</span>
    169. 

  169.             <span class="n">request_serializer</span><span class="p">:</span> <span class="n">SerializingFunction</span><span class="p">,</span>
    170. 

  170.             <span class="n">response_deserializer</span><span class="p">:</span> <span class="n">DeserializingFunction</span><span class="p">,</span>
    171. 

  171.             <span class="n">interceptors</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="n">Sequence</span><span class="p">[</span><span class="n">ClientInterceptor</span><span class="p">]],</span>
    172. 

  172.             <span class="n">loop</span><span class="p">:</span> <span class="n">asyncio</span><span class="o">.</span><span class="n">AbstractEventLoop</span><span class="p">,</span>
    173. 

  173.     <span class="p">)</span> <span class="o">-&gt;</span> <span class="kc">None</span><span class="p">:</span>
    174. 

  174.         <span class="bp">self</span><span class="o">.</span><span class="n">_loop</span> <span class="o">=</span> <span class="n">loop</span>
    175. 

  175.         <span class="bp">self</span><span class="o">.</span><span class="n">_channel</span> <span class="o">=</span> <span class="n">channel</span>
    176. 

  176.         <span class="bp">self</span><span class="o">.</span><span class="n">_method</span> <span class="o">=</span> <span class="n">method</span>
    177. 

  177.         <span class="bp">self</span><span class="o">.</span><span class="n">_request_serializer</span> <span class="o">=</span> <span class="n">request_serializer</span>
    178. 

  178.         <span class="bp">self</span><span class="o">.</span><span class="n">_response_deserializer</span> <span class="o">=</span> <span class="n">response_deserializer</span>
    179. 

  179.         <span class="bp">self</span><span class="o">.</span><span class="n">_interceptors</span> <span class="o">=</span> <span class="n">interceptors</span>
    180. 

  180. 

  181.     <span class="nd">@staticmethod</span>
    182. 

  182.     <span class="k">def</span> <span class="nf">_init_metadata</span><span class="p">(</span><span class="n">metadata</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="n">Metadata</span><span class="p">]</span> <span class="o">=</span> <span class="kc">None</span><span class="p">,</span>
    183. 

  183.                        <span class="n">compression</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="n">grpc</span><span class="o">.</span><span class="n">Compression</span><span class="p">]</span> <span class="o">=</span> <span class="kc">None</span>
    184. 

  184.                       <span class="p">)</span> <span class="o">-&gt;</span> <span class="n">Metadata</span><span class="p">:</span>
    185. 

  185.         <span class="sd">&quot;&quot;&quot;Based on the provided values for &lt;metadata&gt; or &lt;compression&gt; initialise the final</span>
    186. 

  186. <span class="sd">        metadata, as it should be used for the current call.</span>
    187. 

  187. <span class="sd">        &quot;&quot;&quot;</span>
    188. 

  188.         <span class="n">metadata</span> <span class="o">=</span> <span class="n">metadata</span> <span class="ow">or</span> <span class="n">Metadata</span><span class="p">()</span>
    189. 

  189.         <span class="k">if</span> <span class="n">compression</span><span class="p">:</span>
    190. 

  190.             <span class="n">metadata</span> <span class="o">=</span> <span class="n">Metadata</span><span class="p">(</span>
    191. 

  191.                 <span class="o">*</span><span class="n">_compression</span><span class="o">.</span><span class="n">augment_metadata</span><span class="p">(</span><span class="n">metadata</span><span class="p">,</span> <span class="n">compression</span><span class="p">))</span>
    192. 

  192.         <span class="k">return</span> <span class="n">metadata</span>
    193. 

  193. 

  194. 

  195. <span class="k">class</span> <span class="nc">UnaryUnaryMultiCallable</span><span class="p">(</span><span class="n">_BaseMultiCallable</span><span class="p">,</span>
    196. 

  196.                               <span class="n">_base_channel</span><span class="o">.</span><span class="n">UnaryUnaryMultiCallable</span><span class="p">):</span>
    197. 

  197. 

  198.     <span class="k">def</span> <span class="fm">__call__</span><span class="p">(</span><span class="bp">self</span><span class="p">,</span>
    199. 

  199.                  <span class="n">request</span><span class="p">:</span> <span class="n">Any</span><span class="p">,</span>
    200. 

  200.                  <span class="o">*</span><span class="p">,</span>
    201. 

  201.                  <span class="n">timeout</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="nb">float</span><span class="p">]</span> <span class="o">=</span> <span class="kc">None</span><span class="p">,</span>
    202. 

  202.                  <span class="n">metadata</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="n">Metadata</span><span class="p">]</span> <span class="o">=</span> <span class="kc">None</span><span class="p">,</span>
    203. 

  203.                  <span class="n">credentials</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="n">grpc</span><span class="o">.</span><span class="n">CallCredentials</span><span class="p">]</span> <span class="o">=</span> <span class="kc">None</span><span class="p">,</span>
    204. 

  204.                  <span class="n">wait_for_ready</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="nb">bool</span><span class="p">]</span> <span class="o">=</span> <span class="kc">None</span><span class="p">,</span>
    205. 

  205.                  <span class="n">compression</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="n">grpc</span><span class="o">.</span><span class="n">Compression</span><span class="p">]</span> <span class="o">=</span> <span class="kc">None</span>
    206. 

  206.                 <span class="p">)</span> <span class="o">-&gt;</span> <span class="n">_base_call</span><span class="o">.</span><span class="n">UnaryUnaryCall</span><span class="p">:</span>
    207. 

  207. 

  208.         <span class="n">metadata</span> <span class="o">=</span> <span class="bp">self</span><span class="o">.</span><span class="n">_init_metadata</span><span class="p">(</span><span class="n">metadata</span><span class="p">,</span> <span class="n">compression</span><span class="p">)</span>
    209. 

  209.         <span class="k">if</span> <span class="ow">not</span> <span class="bp">self</span><span class="o">.</span><span class="n">_interceptors</span><span class="p">:</span>
    210. 

  210.             <span class="n">call</span> <span class="o">=</span> <span class="n">UnaryUnaryCall</span><span class="p">(</span><span class="n">request</span><span class="p">,</span> <span class="n">_timeout_to_deadline</span><span class="p">(</span><span class="n">timeout</span><span class="p">),</span>
    211. 

  211.                                   <span class="n">metadata</span><span class="p">,</span> <span class="n">credentials</span><span class="p">,</span> <span class="n">wait_for_ready</span><span class="p">,</span>
    212. 

  212.                                   <span class="bp">self</span><span class="o">.</span><span class="n">_channel</span><span class="p">,</span> <span class="bp">self</span><span class="o">.</span><span class="n">_method</span><span class="p">,</span>
    213. 

  213.                                   <span class="bp">self</span><span class="o">.</span><span class="n">_request_serializer</span><span class="p">,</span>
    214. 

  214.                                   <span class="bp">self</span><span class="o">.</span><span class="n">_response_deserializer</span><span class="p">,</span> <span class="bp">self</span><span class="o">.</span><span class="n">_loop</span><span class="p">)</span>
    215. 

  215.         <span class="k">else</span><span class="p">:</span>
    216. 

  216.             <span class="n">call</span> <span class="o">=</span> <span class="n">InterceptedUnaryUnaryCall</span><span class="p">(</span>
    217. 

  217.                 <span class="bp">self</span><span class="o">.</span><span class="n">_interceptors</span><span class="p">,</span> <span class="n">request</span><span class="p">,</span> <span class="n">timeout</span><span class="p">,</span> <span class="n">metadata</span><span class="p">,</span> <span class="n">credentials</span><span class="p">,</span>
    218. 

  218.                 <span class="n">wait_for_ready</span><span class="p">,</span> <span class="bp">self</span><span class="o">.</span><span class="n">_channel</span><span class="p">,</span> <span class="bp">self</span><span class="o">.</span><span class="n">_method</span><span class="p">,</span>
    219. 

  219.                 <span class="bp">self</span><span class="o">.</span><span class="n">_request_serializer</span><span class="p">,</span> <span class="bp">self</span><span class="o">.</span><span class="n">_response_deserializer</span><span class="p">,</span>
    220. 

  220.                 <span class="bp">self</span><span class="o">.</span><span class="n">_loop</span><span class="p">)</span>
    221. 

  221. 

  222.         <span class="k">return</span> <span class="n">call</span>
    223. 

  223. 

  224. 

  225. <span class="k">class</span> <span class="nc">UnaryStreamMultiCallable</span><span class="p">(</span><span class="n">_BaseMultiCallable</span><span class="p">,</span>
    226. 

  226.                                <span class="n">_base_channel</span><span class="o">.</span><span class="n">UnaryStreamMultiCallable</span><span class="p">):</span>
    227. 

  227. 

  228.     <span class="k">def</span> <span class="fm">__call__</span><span class="p">(</span><span class="bp">self</span><span class="p">,</span>
    229. 

  229.                  <span class="n">request</span><span class="p">:</span> <span class="n">Any</span><span class="p">,</span>
    230. 

  230.                  <span class="o">*</span><span class="p">,</span>
    231. 

  231.                  <span class="n">timeout</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="nb">float</span><span class="p">]</span> <span class="o">=</span> <span class="kc">None</span><span class="p">,</span>
    232. 

  232.                  <span class="n">metadata</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="n">Metadata</span><span class="p">]</span> <span class="o">=</span> <span class="kc">None</span><span class="p">,</span>
    233. 

  233.                  <span class="n">credentials</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="n">grpc</span><span class="o">.</span><span class="n">CallCredentials</span><span class="p">]</span> <span class="o">=</span> <span class="kc">None</span><span class="p">,</span>
    234. 

  234.                  <span class="n">wait_for_ready</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="nb">bool</span><span class="p">]</span> <span class="o">=</span> <span class="kc">None</span><span class="p">,</span>
    235. 

  235.                  <span class="n">compression</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="n">grpc</span><span class="o">.</span><span class="n">Compression</span><span class="p">]</span> <span class="o">=</span> <span class="kc">None</span>
    236. 

  236.                 <span class="p">)</span> <span class="o">-&gt;</span> <span class="n">_base_call</span><span class="o">.</span><span class="n">UnaryStreamCall</span><span class="p">:</span>
    237. 

  237. 

  238.         <span class="n">metadata</span> <span class="o">=</span> <span class="bp">self</span><span class="o">.</span><span class="n">_init_metadata</span><span class="p">(</span><span class="n">metadata</span><span class="p">,</span> <span class="n">compression</span><span class="p">)</span>
    239. 

  239.         <span class="n">deadline</span> <span class="o">=</span> <span class="n">_timeout_to_deadline</span><span class="p">(</span><span class="n">timeout</span><span class="p">)</span>
    240. 

  240. 

  241.         <span class="k">if</span> <span class="ow">not</span> <span class="bp">self</span><span class="o">.</span><span class="n">_interceptors</span><span class="p">:</span>
    242. 

  242.             <span class="n">call</span> <span class="o">=</span> <span class="n">UnaryStreamCall</span><span class="p">(</span><span class="n">request</span><span class="p">,</span> <span class="n">deadline</span><span class="p">,</span> <span class="n">metadata</span><span class="p">,</span> <span class="n">credentials</span><span class="p">,</span>
    243. 

  243.                                    <span class="n">wait_for_ready</span><span class="p">,</span> <span class="bp">self</span><span class="o">.</span><span class="n">_channel</span><span class="p">,</span> <span class="bp">self</span><span class="o">.</span><span class="n">_method</span><span class="p">,</span>
    244. 

  244.                                    <span class="bp">self</span><span class="o">.</span><span class="n">_request_serializer</span><span class="p">,</span>
    245. 

  245.                                    <span class="bp">self</span><span class="o">.</span><span class="n">_response_deserializer</span><span class="p">,</span> <span class="bp">self</span><span class="o">.</span><span class="n">_loop</span><span class="p">)</span>
    246. 

  246.         <span class="k">else</span><span class="p">:</span>
    247. 

  247.             <span class="n">call</span> <span class="o">=</span> <span class="n">InterceptedUnaryStreamCall</span><span class="p">(</span>
    248. 

  248.                 <span class="bp">self</span><span class="o">.</span><span class="n">_interceptors</span><span class="p">,</span> <span class="n">request</span><span class="p">,</span> <span class="n">deadline</span><span class="p">,</span> <span class="n">metadata</span><span class="p">,</span> <span class="n">credentials</span><span class="p">,</span>
    249. 

  249.                 <span class="n">wait_for_ready</span><span class="p">,</span> <span class="bp">self</span><span class="o">.</span><span class="n">_channel</span><span class="p">,</span> <span class="bp">self</span><span class="o">.</span><span class="n">_method</span><span class="p">,</span>
    250. 

  250.                 <span class="bp">self</span><span class="o">.</span><span class="n">_request_serializer</span><span class="p">,</span> <span class="bp">self</span><span class="o">.</span><span class="n">_response_deserializer</span><span class="p">,</span>
    251. 

  251.                 <span class="bp">self</span><span class="o">.</span><span class="n">_loop</span><span class="p">)</span>
    252. 

  252. 

  253.         <span class="k">return</span> <span class="n">call</span>
    254. 

  254. 

  255. 

  256. <span class="k">class</span> <span class="nc">StreamUnaryMultiCallable</span><span class="p">(</span><span class="n">_BaseMultiCallable</span><span class="p">,</span>
    257. 

  257.                                <span class="n">_base_channel</span><span class="o">.</span><span class="n">StreamUnaryMultiCallable</span><span class="p">):</span>
    258. 

  258. 

  259.     <span class="k">def</span> <span class="fm">__call__</span><span class="p">(</span><span class="bp">self</span><span class="p">,</span>
    260. 

  260.                  <span class="n">request_iterator</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="n">RequestIterableType</span><span class="p">]</span> <span class="o">=</span> <span class="kc">None</span><span class="p">,</span>
    261. 

  261.                  <span class="n">timeout</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="nb">float</span><span class="p">]</span> <span class="o">=</span> <span class="kc">None</span><span class="p">,</span>
    262. 

  262.                  <span class="n">metadata</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="n">Metadata</span><span class="p">]</span> <span class="o">=</span> <span class="kc">None</span><span class="p">,</span>
    263. 

  263.                  <span class="n">credentials</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="n">grpc</span><span class="o">.</span><span class="n">CallCredentials</span><span class="p">]</span> <span class="o">=</span> <span class="kc">None</span><span class="p">,</span>
    264. 

  264.                  <span class="n">wait_for_ready</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="nb">bool</span><span class="p">]</span> <span class="o">=</span> <span class="kc">None</span><span class="p">,</span>
    265. 

  265.                  <span class="n">compression</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="n">grpc</span><span class="o">.</span><span class="n">Compression</span><span class="p">]</span> <span class="o">=</span> <span class="kc">None</span>
    266. 

  266.                 <span class="p">)</span> <span class="o">-&gt;</span> <span class="n">_base_call</span><span class="o">.</span><span class="n">StreamUnaryCall</span><span class="p">:</span>
    267. 

  267. 

  268.         <span class="n">metadata</span> <span class="o">=</span> <span class="bp">self</span><span class="o">.</span><span class="n">_init_metadata</span><span class="p">(</span><span class="n">metadata</span><span class="p">,</span> <span class="n">compression</span><span class="p">)</span>
    269. 

  269.         <span class="n">deadline</span> <span class="o">=</span> <span class="n">_timeout_to_deadline</span><span class="p">(</span><span class="n">timeout</span><span class="p">)</span>
    270. 

  270. 

  271.         <span class="k">if</span> <span class="ow">not</span> <span class="bp">self</span><span class="o">.</span><span class="n">_interceptors</span><span class="p">:</span>
    272. 

  272.             <span class="n">call</span> <span class="o">=</span> <span class="n">StreamUnaryCall</span><span class="p">(</span><span class="n">request_iterator</span><span class="p">,</span> <span class="n">deadline</span><span class="p">,</span> <span class="n">metadata</span><span class="p">,</span>
    273. 

  273.                                    <span class="n">credentials</span><span class="p">,</span> <span class="n">wait_for_ready</span><span class="p">,</span> <span class="bp">self</span><span class="o">.</span><span class="n">_channel</span><span class="p">,</span>
    274. 

  274.                                    <span class="bp">self</span><span class="o">.</span><span class="n">_method</span><span class="p">,</span> <span class="bp">self</span><span class="o">.</span><span class="n">_request_serializer</span><span class="p">,</span>
    275. 

  275.                                    <span class="bp">self</span><span class="o">.</span><span class="n">_response_deserializer</span><span class="p">,</span> <span class="bp">self</span><span class="o">.</span><span class="n">_loop</span><span class="p">)</span>
    276. 

  276.         <span class="k">else</span><span class="p">:</span>
    277. 

  277.             <span class="n">call</span> <span class="o">=</span> <span class="n">InterceptedStreamUnaryCall</span><span class="p">(</span>
    278. 

  278.                 <span class="bp">self</span><span class="o">.</span><span class="n">_interceptors</span><span class="p">,</span> <span class="n">request_iterator</span><span class="p">,</span> <span class="n">deadline</span><span class="p">,</span> <span class="n">metadata</span><span class="p">,</span>
    279. 

  279.                 <span class="n">credentials</span><span class="p">,</span> <span class="n">wait_for_ready</span><span class="p">,</span> <span class="bp">self</span><span class="o">.</span><span class="n">_channel</span><span class="p">,</span> <span class="bp">self</span><span class="o">.</span><span class="n">_method</span><span class="p">,</span>
    280. 

  280.                 <span class="bp">self</span><span class="o">.</span><span class="n">_request_serializer</span><span class="p">,</span> <span class="bp">self</span><span class="o">.</span><span class="n">_response_deserializer</span><span class="p">,</span>
    281. 

  281.                 <span class="bp">self</span><span class="o">.</span><span class="n">_loop</span><span class="p">)</span>
    282. 

  282. 

  283.         <span class="k">return</span> <span class="n">call</span>
    284. 

  284. 

  285. 

  286. <span class="k">class</span> <span class="nc">StreamStreamMultiCallable</span><span class="p">(</span><span class="n">_BaseMultiCallable</span><span class="p">,</span>
    287. 

  287.                                 <span class="n">_base_channel</span><span class="o">.</span><span class="n">StreamStreamMultiCallable</span><span class="p">):</span>
    288. 

  288. 

  289.     <span class="k">def</span> <span class="fm">__call__</span><span class="p">(</span><span class="bp">self</span><span class="p">,</span>
    290. 

  290.                  <span class="n">request_iterator</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="n">RequestIterableType</span><span class="p">]</span> <span class="o">=</span> <span class="kc">None</span><span class="p">,</span>
    291. 

  291.                  <span class="n">timeout</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="nb">float</span><span class="p">]</span> <span class="o">=</span> <span class="kc">None</span><span class="p">,</span>
    292. 

  292.                  <span class="n">metadata</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="n">Metadata</span><span class="p">]</span> <span class="o">=</span> <span class="kc">None</span><span class="p">,</span>
    293. 

  293.                  <span class="n">credentials</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="n">grpc</span><span class="o">.</span><span class="n">CallCredentials</span><span class="p">]</span> <span class="o">=</span> <span class="kc">None</span><span class="p">,</span>
    294. 

  294.                  <span class="n">wait_for_ready</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="nb">bool</span><span class="p">]</span> <span class="o">=</span> <span class="kc">None</span><span class="p">,</span>
    295. 

  295.                  <span class="n">compression</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="n">grpc</span><span class="o">.</span><span class="n">Compression</span><span class="p">]</span> <span class="o">=</span> <span class="kc">None</span>
    296. 

  296.                 <span class="p">)</span> <span class="o">-&gt;</span> <span class="n">_base_call</span><span class="o">.</span><span class="n">StreamStreamCall</span><span class="p">:</span>
    297. 

  297. 

  298.         <span class="n">metadata</span> <span class="o">=</span> <span class="bp">self</span><span class="o">.</span><span class="n">_init_metadata</span><span class="p">(</span><span class="n">metadata</span><span class="p">,</span> <span class="n">compression</span><span class="p">)</span>
    299. 

  299.         <span class="n">deadline</span> <span class="o">=</span> <span class="n">_timeout_to_deadline</span><span class="p">(</span><span class="n">timeout</span><span class="p">)</span>
    300. 

  300. 

  301.         <span class="k">if</span> <span class="ow">not</span> <span class="bp">self</span><span class="o">.</span><span class="n">_interceptors</span><span class="p">:</span>
    302. 

  302.             <span class="n">call</span> <span class="o">=</span> <span class="n">StreamStreamCall</span><span class="p">(</span><span class="n">request_iterator</span><span class="p">,</span> <span class="n">deadline</span><span class="p">,</span> <span class="n">metadata</span><span class="p">,</span>
    303. 

  303.                                     <span class="n">credentials</span><span class="p">,</span> <span class="n">wait_for_ready</span><span class="p">,</span> <span class="bp">self</span><span class="o">.</span><span class="n">_channel</span><span class="p">,</span>
    304. 

  304.                                     <span class="bp">self</span><span class="o">.</span><span class="n">_method</span><span class="p">,</span> <span class="bp">self</span><span class="o">.</span><span class="n">_request_serializer</span><span class="p">,</span>
    305. 

  305.                                     <span class="bp">self</span><span class="o">.</span><span class="n">_response_deserializer</span><span class="p">,</span> <span class="bp">self</span><span class="o">.</span><span class="n">_loop</span><span class="p">)</span>
    306. 

  306.         <span class="k">else</span><span class="p">:</span>
    307. 

  307.             <span class="n">call</span> <span class="o">=</span> <span class="n">InterceptedStreamStreamCall</span><span class="p">(</span>
    308. 

  308.                 <span class="bp">self</span><span class="o">.</span><span class="n">_interceptors</span><span class="p">,</span> <span class="n">request_iterator</span><span class="p">,</span> <span class="n">deadline</span><span class="p">,</span> <span class="n">metadata</span><span class="p">,</span>
    309. 

  309.                 <span class="n">credentials</span><span class="p">,</span> <span class="n">wait_for_ready</span><span class="p">,</span> <span class="bp">self</span><span class="o">.</span><span class="n">_channel</span><span class="p">,</span> <span class="bp">self</span><span class="o">.</span><span class="n">_method</span><span class="p">,</span>
    310. 

  310.                 <span class="bp">self</span><span class="o">.</span><span class="n">_request_serializer</span><span class="p">,</span> <span class="bp">self</span><span class="o">.</span><span class="n">_response_deserializer</span><span class="p">,</span>
    311. 

  311.                 <span class="bp">self</span><span class="o">.</span><span class="n">_loop</span><span class="p">)</span>
    312. 

  312. 

  313.         <span class="k">return</span> <span class="n">call</span>
    314. 

  314. 

  315. 

  316. <span class="k">class</span> <span class="nc">Channel</span><span class="p">(</span><span class="n">_base_channel</span><span class="o">.</span><span class="n">Channel</span><span class="p">):</span>
    317. 

  317.     <span class="n">_loop</span><span class="p">:</span> <span class="n">asyncio</span><span class="o">.</span><span class="n">AbstractEventLoop</span>
    318. 

  318.     <span class="n">_channel</span><span class="p">:</span> <span class="n">cygrpc</span><span class="o">.</span><span class="n">AioChannel</span>
    319. 

  319.     <span class="n">_unary_unary_interceptors</span><span class="p">:</span> <span class="n">List</span><span class="p">[</span><span class="n">UnaryUnaryClientInterceptor</span><span class="p">]</span>
    320. 

  320.     <span class="n">_unary_stream_interceptors</span><span class="p">:</span> <span class="n">List</span><span class="p">[</span><span class="n">UnaryStreamClientInterceptor</span><span class="p">]</span>
    321. 

  321.     <span class="n">_stream_unary_interceptors</span><span class="p">:</span> <span class="n">List</span><span class="p">[</span><span class="n">StreamUnaryClientInterceptor</span><span class="p">]</span>
    322. 

  322.     <span class="n">_stream_stream_interceptors</span><span class="p">:</span> <span class="n">List</span><span class="p">[</span><span class="n">StreamStreamClientInterceptor</span><span class="p">]</span>
    323. 

  323. 

  324.     <span class="k">def</span> <span class="fm">__init__</span><span class="p">(</span><span class="bp">self</span><span class="p">,</span> <span class="n">target</span><span class="p">:</span> <span class="nb">str</span><span class="p">,</span> <span class="n">options</span><span class="p">:</span> <span class="n">ChannelArgumentType</span><span class="p">,</span>
    325. 

  325.                  <span class="n">credentials</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="n">grpc</span><span class="o">.</span><span class="n">ChannelCredentials</span><span class="p">],</span>
    326. 

  326.                  <span class="n">compression</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="n">grpc</span><span class="o">.</span><span class="n">Compression</span><span class="p">],</span>
    327. 

  327.                  <span class="n">interceptors</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="n">Sequence</span><span class="p">[</span><span class="n">ClientInterceptor</span><span class="p">]]):</span>
    328. 

  328.         <span class="sd">&quot;&quot;&quot;Constructor.</span>
    329. 

  329. 

  330. <span class="sd">        Args:</span>
    331. 

  331. <span class="sd">          target: The target to which to connect.</span>
    332. 

  332. <span class="sd">          options: Configuration options for the channel.</span>
    333. 

  333. <span class="sd">          credentials: A cygrpc.ChannelCredentials or None.</span>
    334. 

  334. <span class="sd">          compression: An optional value indicating the compression method to be</span>
    335. 

  335. <span class="sd">            used over the lifetime of the channel.</span>
    336. 

  336. <span class="sd">          interceptors: An optional list of interceptors that would be used for</span>
    337. 

  337. <span class="sd">            intercepting any RPC executed with that channel.</span>
    338. 

  338. <span class="sd">        &quot;&quot;&quot;</span>
    339. 

  339.         <span class="bp">self</span><span class="o">.</span><span class="n">_unary_unary_interceptors</span> <span class="o">=</span> <span class="p">[]</span>
    340. 

  340.         <span class="bp">self</span><span class="o">.</span><span class="n">_unary_stream_interceptors</span> <span class="o">=</span> <span class="p">[]</span>
    341. 

  341.         <span class="bp">self</span><span class="o">.</span><span class="n">_stream_unary_interceptors</span> <span class="o">=</span> <span class="p">[]</span>
    342. 

  342.         <span class="bp">self</span><span class="o">.</span><span class="n">_stream_stream_interceptors</span> <span class="o">=</span> <span class="p">[]</span>
    343. 

  343. 

  344.         <span class="k">if</span> <span class="n">interceptors</span> <span class="ow">is</span> <span class="ow">not</span> <span class="kc">None</span><span class="p">:</span>
    345. 

  345.             <span class="k">for</span> <span class="n">interceptor</span> <span class="ow">in</span> <span class="n">interceptors</span><span class="p">:</span>
    346. 

  346.                 <span class="k">if</span> <span class="nb">isinstance</span><span class="p">(</span><span class="n">interceptor</span><span class="p">,</span> <span class="n">UnaryUnaryClientInterceptor</span><span class="p">):</span>
    347. 

  347.                     <span class="bp">self</span><span class="o">.</span><span class="n">_unary_unary_interceptors</span><span class="o">.</span><span class="n">append</span><span class="p">(</span><span class="n">interceptor</span><span class="p">)</span>
    348. 

  348.                 <span class="k">elif</span> <span class="nb">isinstance</span><span class="p">(</span><span class="n">interceptor</span><span class="p">,</span> <span class="n">UnaryStreamClientInterceptor</span><span class="p">):</span>
    349. 

  349.                     <span class="bp">self</span><span class="o">.</span><span class="n">_unary_stream_interceptors</span><span class="o">.</span><span class="n">append</span><span class="p">(</span><span class="n">interceptor</span><span class="p">)</span>
    350. 

  350.                 <span class="k">elif</span> <span class="nb">isinstance</span><span class="p">(</span><span class="n">interceptor</span><span class="p">,</span> <span class="n">StreamUnaryClientInterceptor</span><span class="p">):</span>
    351. 

  351.                     <span class="bp">self</span><span class="o">.</span><span class="n">_stream_unary_interceptors</span><span class="o">.</span><span class="n">append</span><span class="p">(</span><span class="n">interceptor</span><span class="p">)</span>
    352. 

  352.                 <span class="k">elif</span> <span class="nb">isinstance</span><span class="p">(</span><span class="n">interceptor</span><span class="p">,</span> <span class="n">StreamStreamClientInterceptor</span><span class="p">):</span>
    353. 

  353.                     <span class="bp">self</span><span class="o">.</span><span class="n">_stream_stream_interceptors</span><span class="o">.</span><span class="n">append</span><span class="p">(</span><span class="n">interceptor</span><span class="p">)</span>
    354. 

  354.                 <span class="k">else</span><span class="p">:</span>
    355. 

  355.                     <span class="k">raise</span> <span class="ne">ValueError</span><span class="p">(</span>
    356. 

  356.                         <span class="s2">&quot;Interceptor </span><span class="si">{}</span><span class="s2"> must be &quot;</span><span class="o">.</span><span class="n">format</span><span class="p">(</span><span class="n">interceptor</span><span class="p">)</span> <span class="o">+</span>
    357. 

  357.                         <span class="s2">&quot;</span><span class="si">{}</span><span class="s2"> or &quot;</span><span class="o">.</span><span class="n">format</span><span class="p">(</span><span class="n">UnaryUnaryClientInterceptor</span><span class="o">.</span><span class="vm">__name__</span><span class="p">)</span> <span class="o">+</span>
    358. 

  358.                         <span class="s2">&quot;</span><span class="si">{}</span><span class="s2"> or &quot;</span><span class="o">.</span><span class="n">format</span><span class="p">(</span><span class="n">UnaryStreamClientInterceptor</span><span class="o">.</span><span class="vm">__name__</span><span class="p">)</span> <span class="o">+</span>
    359. 

  359.                         <span class="s2">&quot;</span><span class="si">{}</span><span class="s2"> or &quot;</span><span class="o">.</span><span class="n">format</span><span class="p">(</span><span class="n">StreamUnaryClientInterceptor</span><span class="o">.</span><span class="vm">__name__</span><span class="p">)</span> <span class="o">+</span>
    360. 

  360.                         <span class="s2">&quot;</span><span class="si">{}</span><span class="s2">. &quot;</span><span class="o">.</span><span class="n">format</span><span class="p">(</span><span class="n">StreamStreamClientInterceptor</span><span class="o">.</span><span class="vm">__name__</span><span class="p">))</span>
    361. 

  361. 

  362.         <span class="bp">self</span><span class="o">.</span><span class="n">_loop</span> <span class="o">=</span> <span class="n">cygrpc</span><span class="o">.</span><span class="n">get_working_loop</span><span class="p">()</span>
    363. 

  363.         <span class="bp">self</span><span class="o">.</span><span class="n">_channel</span> <span class="o">=</span> <span class="n">cygrpc</span><span class="o">.</span><span class="n">AioChannel</span><span class="p">(</span>
    364. 

  364.             <span class="n">_common</span><span class="o">.</span><span class="n">encode</span><span class="p">(</span><span class="n">target</span><span class="p">),</span>
    365. 

  365.             <span class="n">_augment_channel_arguments</span><span class="p">(</span><span class="n">options</span><span class="p">,</span> <span class="n">compression</span><span class="p">),</span> <span class="n">credentials</span><span class="p">,</span>
    366. 

  366.             <span class="bp">self</span><span class="o">.</span><span class="n">_loop</span><span class="p">)</span>
    367. 

  367. 

  368.     <span class="k">async</span> <span class="k">def</span> <span class="fm">__aenter__</span><span class="p">(</span><span class="bp">self</span><span class="p">):</span>
    369. 

  369.         <span class="k">return</span> <span class="bp">self</span>
    370. 

  370. 

  371.     <span class="k">async</span> <span class="k">def</span> <span class="fm">__aexit__</span><span class="p">(</span><span class="bp">self</span><span class="p">,</span> <span class="n">exc_type</span><span class="p">,</span> <span class="n">exc_val</span><span class="p">,</span> <span class="n">exc_tb</span><span class="p">):</span>
    372. 

  372.         <span class="k">await</span> <span class="bp">self</span><span class="o">.</span><span class="n">_close</span><span class="p">(</span><span class="kc">None</span><span class="p">)</span>
    373. 

  373. 

  374.     <span class="k">async</span> <span class="k">def</span> <span class="nf">_close</span><span class="p">(</span><span class="bp">self</span><span class="p">,</span> <span class="n">grace</span><span class="p">):</span>  <span class="c1"># pylint: disable=too-many-branches</span>
    375. 

  375.         <span class="k">if</span> <span class="bp">self</span><span class="o">.</span><span class="n">_channel</span><span class="o">.</span><span class="n">closed</span><span class="p">():</span>
    376. 

  376.             <span class="k">return</span>
    377. 

  377. 

  378.         <span class="c1"># No new calls will be accepted by the Cython channel.</span>
    379. 

  379.         <span class="bp">self</span><span class="o">.</span><span class="n">_channel</span><span class="o">.</span><span class="n">closing</span><span class="p">()</span>
    380. 

  380. 

  381.         <span class="c1"># Iterate through running tasks</span>
    382. 

  382.         <span class="n">tasks</span> <span class="o">=</span> <span class="n">_all_tasks</span><span class="p">()</span>
    383. 

  383.         <span class="n">calls</span> <span class="o">=</span> <span class="p">[]</span>
    384. 

  384.         <span class="n">call_tasks</span> <span class="o">=</span> <span class="p">[]</span>
    385. 

  385.         <span class="k">for</span> <span class="n">task</span> <span class="ow">in</span> <span class="n">tasks</span><span class="p">:</span>
    386. 

  386.             <span class="k">try</span><span class="p">:</span>
    387. 

  387.                 <span class="n">stack</span> <span class="o">=</span> <span class="n">task</span><span class="o">.</span><span class="n">get_stack</span><span class="p">(</span><span class="n">limit</span><span class="o">=</span><span class="mi">1</span><span class="p">)</span>
    388. 

  388.             <span class="k">except</span> <span class="ne">AttributeError</span> <span class="k">as</span> <span class="n">attribute_error</span><span class="p">:</span>
    389. 

  389.                 <span class="c1"># NOTE(lidiz) tl;dr: If the Task is created with a CPython</span>
    390. 

  390.                 <span class="c1"># object, it will trigger AttributeError.</span>
    391. 

  391.                 <span class="c1">#</span>
    392. 

  392.                 <span class="c1"># In the global finalizer, the event loop schedules</span>
    393. 

  393.                 <span class="c1"># a CPython PyAsyncGenAThrow object.</span>
    394. 

  394.                 <span class="c1"># https://github.com/python/cpython/blob/00e45877e33d32bb61aa13a2033e3bba370bda4d/Lib/asyncio/base_events.py#L484</span>
    395. 

  395.                 <span class="c1">#</span>
    396. 

  396.                 <span class="c1"># However, the PyAsyncGenAThrow object is written in C and</span>
    397. 

  397.                 <span class="c1"># failed to include the normal Python frame objects. Hence,</span>
    398. 

  398.                 <span class="c1"># this exception is a false negative, and it is safe to ignore</span>
    399. 

  399.                 <span class="c1"># the failure. It is fixed by https://github.com/python/cpython/pull/18669,</span>
    400. 

  400.                 <span class="c1"># but not available until 3.9 or 3.8.3. So, we have to keep it</span>
    401. 

  401.                 <span class="c1"># for a while.</span>
    402. 

  402.                 <span class="c1"># TODO(lidiz) drop this hack after 3.8 deprecation</span>
    403. 

  403.                 <span class="k">if</span> <span class="s1">&#39;frame&#39;</span> <span class="ow">in</span> <span class="nb">str</span><span class="p">(</span><span class="n">attribute_error</span><span class="p">):</span>
    404. 

  404.                     <span class="k">continue</span>
    405. 

  405.                 <span class="k">else</span><span class="p">:</span>
    406. 

  406.                     <span class="k">raise</span>
    407. 

  407. 

  408.             <span class="c1"># If the Task is created by a C-extension, the stack will be empty.</span>
    409. 

  409.             <span class="k">if</span> <span class="ow">not</span> <span class="n">stack</span><span class="p">:</span>
    410. 

  410.                 <span class="k">continue</span>
    411. 

  411. 

  412.             <span class="c1"># Locate ones created by `aio.Call`.</span>
    413. 

  413.             <span class="n">frame</span> <span class="o">=</span> <span class="n">stack</span><span class="p">[</span><span class="mi">0</span><span class="p">]</span>
    414. 

  414.             <span class="n">candidate</span> <span class="o">=</span> <span class="n">frame</span><span class="o">.</span><span class="n">f_locals</span><span class="o">.</span><span class="n">get</span><span class="p">(</span><span class="s1">&#39;self&#39;</span><span class="p">)</span>
    415. 

  415.             <span class="k">if</span> <span class="n">candidate</span><span class="p">:</span>
    416. 

  416.                 <span class="k">if</span> <span class="nb">isinstance</span><span class="p">(</span><span class="n">candidate</span><span class="p">,</span> <span class="n">_base_call</span><span class="o">.</span><span class="n">Call</span><span class="p">):</span>
    417. 

  417.                     <span class="k">if</span> <span class="nb">hasattr</span><span class="p">(</span><span class="n">candidate</span><span class="p">,</span> <span class="s1">&#39;_channel&#39;</span><span class="p">):</span>
    418. 

  418.                         <span class="c1"># For intercepted Call object</span>
    419. 

  419.                         <span class="k">if</span> <span class="n">candidate</span><span class="o">.</span><span class="n">_channel</span> <span class="ow">is</span> <span class="ow">not</span> <span class="bp">self</span><span class="o">.</span><span class="n">_channel</span><span class="p">:</span>
    420. 

  420.                             <span class="k">continue</span>
    421. 

  421.                     <span class="k">elif</span> <span class="nb">hasattr</span><span class="p">(</span><span class="n">candidate</span><span class="p">,</span> <span class="s1">&#39;_cython_call&#39;</span><span class="p">):</span>
    422. 

  422.                         <span class="c1"># For normal Call object</span>
    423. 

  423.                         <span class="k">if</span> <span class="n">candidate</span><span class="o">.</span><span class="n">_cython_call</span><span class="o">.</span><span class="n">_channel</span> <span class="ow">is</span> <span class="ow">not</span> <span class="bp">self</span><span class="o">.</span><span class="n">_channel</span><span class="p">:</span>
    424. 

  424.                             <span class="k">continue</span>
    425. 

  425.                     <span class="k">else</span><span class="p">:</span>
    426. 

  426.                         <span class="c1"># Unidentified Call object</span>
    427. 

  427.                         <span class="k">raise</span> <span class="n">cygrpc</span><span class="o">.</span><span class="n">InternalError</span><span class="p">(</span>
    428. 

  428.                             <span class="sa">f</span><span class="s1">&#39;Unrecognized call object: </span><span class="si">{</span><span class="n">candidate</span><span class="si">}</span><span class="s1">&#39;</span><span class="p">)</span>
    429. 

  429. 

  430.                     <span class="n">calls</span><span class="o">.</span><span class="n">append</span><span class="p">(</span><span class="n">candidate</span><span class="p">)</span>
    431. 

  431.                     <span class="n">call_tasks</span><span class="o">.</span><span class="n">append</span><span class="p">(</span><span class="n">task</span><span class="p">)</span>
    432. 

  432. 

  433.         <span class="c1"># If needed, try to wait for them to finish.</span>
    434. 

  434.         <span class="c1"># Call objects are not always awaitables.</span>
    435. 

  435.         <span class="k">if</span> <span class="n">grace</span> <span class="ow">and</span> <span class="n">call_tasks</span><span class="p">:</span>
    436. 

  436.             <span class="k">await</span> <span class="n">asyncio</span><span class="o">.</span><span class="n">wait</span><span class="p">(</span><span class="n">call_tasks</span><span class="p">,</span> <span class="n">timeout</span><span class="o">=</span><span class="n">grace</span><span class="p">,</span> <span class="n">loop</span><span class="o">=</span><span class="bp">self</span><span class="o">.</span><span class="n">_loop</span><span class="p">)</span>
    437. 

  437. 

  438.         <span class="c1"># Time to cancel existing calls.</span>
    439. 

  439.         <span class="k">for</span> <span class="n">call</span> <span class="ow">in</span> <span class="n">calls</span><span class="p">:</span>
    440. 

  440.             <span class="n">call</span><span class="o">.</span><span class="n">cancel</span><span class="p">()</span>
    441. 

  441. 

  442.         <span class="c1"># Destroy the channel</span>
    443. 

  443.         <span class="bp">self</span><span class="o">.</span><span class="n">_channel</span><span class="o">.</span><span class="n">close</span><span class="p">()</span>
    444. 

  444. 

  445.     <span class="k">async</span> <span class="k">def</span> <span class="nf">close</span><span class="p">(</span><span class="bp">self</span><span class="p">,</span> <span class="n">grace</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="nb">float</span><span class="p">]</span> <span class="o">=</span> <span class="kc">None</span><span class="p">):</span>
    446. 

  446.         <span class="k">await</span> <span class="bp">self</span><span class="o">.</span><span class="n">_close</span><span class="p">(</span><span class="n">grace</span><span class="p">)</span>
    447. 

  447. 

  448.     <span class="k">def</span> <span class="nf">get_state</span><span class="p">(</span><span class="bp">self</span><span class="p">,</span>
    449. 

  449.                   <span class="n">try_to_connect</span><span class="p">:</span> <span class="nb">bool</span> <span class="o">=</span> <span class="kc">False</span><span class="p">)</span> <span class="o">-&gt;</span> <span class="n">grpc</span><span class="o">.</span><span class="n">ChannelConnectivity</span><span class="p">:</span>
    450. 

  450.         <span class="n">result</span> <span class="o">=</span> <span class="bp">self</span><span class="o">.</span><span class="n">_channel</span><span class="o">.</span><span class="n">check_connectivity_state</span><span class="p">(</span><span class="n">try_to_connect</span><span class="p">)</span>
    451. 

  451.         <span class="k">return</span> <span class="n">_common</span><span class="o">.</span><span class="n">CYGRPC_CONNECTIVITY_STATE_TO_CHANNEL_CONNECTIVITY</span><span class="p">[</span><span class="n">result</span><span class="p">]</span>
    452. 

  452. 

  453.     <span class="k">async</span> <span class="k">def</span> <span class="nf">wait_for_state_change</span><span class="p">(</span>
    454. 

  454.             <span class="bp">self</span><span class="p">,</span>
    455. 

  455.             <span class="n">last_observed_state</span><span class="p">:</span> <span class="n">grpc</span><span class="o">.</span><span class="n">ChannelConnectivity</span><span class="p">,</span>
    456. 

  456.     <span class="p">)</span> <span class="o">-&gt;</span> <span class="kc">None</span><span class="p">:</span>
    457. 

  457.         <span class="k">assert</span> <span class="k">await</span> <span class="bp">self</span><span class="o">.</span><span class="n">_channel</span><span class="o">.</span><span class="n">watch_connectivity_state</span><span class="p">(</span>
    458. 

  458.             <span class="n">last_observed_state</span><span class="o">.</span><span class="n">value</span><span class="p">[</span><span class="mi">0</span><span class="p">],</span> <span class="kc">None</span><span class="p">)</span>
    459. 

  459. 

  460.     <span class="k">async</span> <span class="k">def</span> <span class="nf">channel_ready</span><span class="p">(</span><span class="bp">self</span><span class="p">)</span> <span class="o">-&gt;</span> <span class="kc">None</span><span class="p">:</span>
    461. 

  461.         <span class="n">state</span> <span class="o">=</span> <span class="bp">self</span><span class="o">.</span><span class="n">get_state</span><span class="p">(</span><span class="n">try_to_connect</span><span class="o">=</span><span class="kc">True</span><span class="p">)</span>
    462. 

  462.         <span class="k">while</span> <span class="n">state</span> <span class="o">!=</span> <span class="n">grpc</span><span class="o">.</span><span class="n">ChannelConnectivity</span><span class="o">.</span><span class="n">READY</span><span class="p">:</span>
    463. 

  463.             <span class="k">await</span> <span class="bp">self</span><span class="o">.</span><span class="n">wait_for_state_change</span><span class="p">(</span><span class="n">state</span><span class="p">)</span>
    464. 

  464.             <span class="n">state</span> <span class="o">=</span> <span class="bp">self</span><span class="o">.</span><span class="n">get_state</span><span class="p">(</span><span class="n">try_to_connect</span><span class="o">=</span><span class="kc">True</span><span class="p">)</span>
    465. 

  465. 

  466.     <span class="k">def</span> <span class="nf">unary_unary</span><span class="p">(</span>
    467. 

  467.             <span class="bp">self</span><span class="p">,</span>
    468. 

  468.             <span class="n">method</span><span class="p">:</span> <span class="nb">str</span><span class="p">,</span>
    469. 

  469.             <span class="n">request_serializer</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="n">SerializingFunction</span><span class="p">]</span> <span class="o">=</span> <span class="kc">None</span><span class="p">,</span>
    470. 

  470.             <span class="n">response_deserializer</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="n">DeserializingFunction</span><span class="p">]</span> <span class="o">=</span> <span class="kc">None</span>
    471. 

  471.     <span class="p">)</span> <span class="o">-&gt;</span> <span class="n">UnaryUnaryMultiCallable</span><span class="p">:</span>
    472. 

  472.         <span class="k">return</span> <span class="n">UnaryUnaryMultiCallable</span><span class="p">(</span><span class="bp">self</span><span class="o">.</span><span class="n">_channel</span><span class="p">,</span> <span class="n">_common</span><span class="o">.</span><span class="n">encode</span><span class="p">(</span><span class="n">method</span><span class="p">),</span>
    473. 

  473.                                        <span class="n">request_serializer</span><span class="p">,</span>
    474. 

  474.                                        <span class="n">response_deserializer</span><span class="p">,</span>
    475. 

  475.                                        <span class="bp">self</span><span class="o">.</span><span class="n">_unary_unary_interceptors</span><span class="p">,</span>
    476. 

  476.                                        <span class="bp">self</span><span class="o">.</span><span class="n">_loop</span><span class="p">)</span>
    477. 

  477. 

  478.     <span class="k">def</span> <span class="nf">unary_stream</span><span class="p">(</span>
    479. 

  479.             <span class="bp">self</span><span class="p">,</span>
    480. 

  480.             <span class="n">method</span><span class="p">:</span> <span class="nb">str</span><span class="p">,</span>
    481. 

  481.             <span class="n">request_serializer</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="n">SerializingFunction</span><span class="p">]</span> <span class="o">=</span> <span class="kc">None</span><span class="p">,</span>
    482. 

  482.             <span class="n">response_deserializer</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="n">DeserializingFunction</span><span class="p">]</span> <span class="o">=</span> <span class="kc">None</span>
    483. 

  483.     <span class="p">)</span> <span class="o">-&gt;</span> <span class="n">UnaryStreamMultiCallable</span><span class="p">:</span>
    484. 

  484.         <span class="k">return</span> <span class="n">UnaryStreamMultiCallable</span><span class="p">(</span><span class="bp">self</span><span class="o">.</span><span class="n">_channel</span><span class="p">,</span> <span class="n">_common</span><span class="o">.</span><span class="n">encode</span><span class="p">(</span><span class="n">method</span><span class="p">),</span>
    485. 

  485.                                         <span class="n">request_serializer</span><span class="p">,</span>
    486. 

  486.                                         <span class="n">response_deserializer</span><span class="p">,</span>
    487. 

  487.                                         <span class="bp">self</span><span class="o">.</span><span class="n">_unary_stream_interceptors</span><span class="p">,</span>
    488. 

  488.                                         <span class="bp">self</span><span class="o">.</span><span class="n">_loop</span><span class="p">)</span>
    489. 

  489. 

  490.     <span class="k">def</span> <span class="nf">stream_unary</span><span class="p">(</span>
    491. 

  491.             <span class="bp">self</span><span class="p">,</span>
    492. 

  492.             <span class="n">method</span><span class="p">:</span> <span class="nb">str</span><span class="p">,</span>
    493. 

  493.             <span class="n">request_serializer</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="n">SerializingFunction</span><span class="p">]</span> <span class="o">=</span> <span class="kc">None</span><span class="p">,</span>
    494. 

  494.             <span class="n">response_deserializer</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="n">DeserializingFunction</span><span class="p">]</span> <span class="o">=</span> <span class="kc">None</span>
    495. 

  495.     <span class="p">)</span> <span class="o">-&gt;</span> <span class="n">StreamUnaryMultiCallable</span><span class="p">:</span>
    496. 

  496.         <span class="k">return</span> <span class="n">StreamUnaryMultiCallable</span><span class="p">(</span><span class="bp">self</span><span class="o">.</span><span class="n">_channel</span><span class="p">,</span> <span class="n">_common</span><span class="o">.</span><span class="n">encode</span><span class="p">(</span><span class="n">method</span><span class="p">),</span>
    497. 

  497.                                         <span class="n">request_serializer</span><span class="p">,</span>
    498. 

  498.                                         <span class="n">response_deserializer</span><span class="p">,</span>
    499. 

  499.                                         <span class="bp">self</span><span class="o">.</span><span class="n">_stream_unary_interceptors</span><span class="p">,</span>
    500. 

  500.                                         <span class="bp">self</span><span class="o">.</span><span class="n">_loop</span><span class="p">)</span>
    501. 

  501. 

  502.     <span class="k">def</span> <span class="nf">stream_stream</span><span class="p">(</span>
    503. 

  503.             <span class="bp">self</span><span class="p">,</span>
    504. 

  504.             <span class="n">method</span><span class="p">:</span> <span class="nb">str</span><span class="p">,</span>
    505. 

  505.             <span class="n">request_serializer</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="n">SerializingFunction</span><span class="p">]</span> <span class="o">=</span> <span class="kc">None</span><span class="p">,</span>
    506. 

  506.             <span class="n">response_deserializer</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="n">DeserializingFunction</span><span class="p">]</span> <span class="o">=</span> <span class="kc">None</span>
    507. 

  507.     <span class="p">)</span> <span class="o">-&gt;</span> <span class="n">StreamStreamMultiCallable</span><span class="p">:</span>
    508. 

  508.         <span class="k">return</span> <span class="n">StreamStreamMultiCallable</span><span class="p">(</span><span class="bp">self</span><span class="o">.</span><span class="n">_channel</span><span class="p">,</span> <span class="n">_common</span><span class="o">.</span><span class="n">encode</span><span class="p">(</span><span class="n">method</span><span class="p">),</span>
    509. 

  509.                                          <span class="n">request_serializer</span><span class="p">,</span>
    510. 

  510.                                          <span class="n">response_deserializer</span><span class="p">,</span>
    511. 

  511.                                          <span class="bp">self</span><span class="o">.</span><span class="n">_stream_stream_interceptors</span><span class="p">,</span>
    512. 

  512.                                          <span class="bp">self</span><span class="o">.</span><span class="n">_loop</span><span class="p">)</span>
    513. 

  513. 

  514. 

  515. <div class="viewcode-block" id="insecure_channel"><a class="viewcode-back" href="../../../../grpc_asyncio.html#grpc.experimental.aio.insecure_channel">[docs]</a><span class="k">def</span> <span class="nf">insecure_channel</span><span class="p">(</span>
    516. 

  516.         <span class="n">target</span><span class="p">:</span> <span class="nb">str</span><span class="p">,</span>
    517. 

  517.         <span class="n">options</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="n">ChannelArgumentType</span><span class="p">]</span> <span class="o">=</span> <span class="kc">None</span><span class="p">,</span>
    518. 

  518.         <span class="n">compression</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="n">grpc</span><span class="o">.</span><span class="n">Compression</span><span class="p">]</span> <span class="o">=</span> <span class="kc">None</span><span class="p">,</span>
    519. 

  519.         <span class="n">interceptors</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="n">Sequence</span><span class="p">[</span><span class="n">ClientInterceptor</span><span class="p">]]</span> <span class="o">=</span> <span class="kc">None</span><span class="p">):</span>
    520. 

  520.     <span class="sd">&quot;&quot;&quot;Creates an insecure asynchronous Channel to a server.</span>
    521. 

  521. 

  522. <span class="sd">    Args:</span>
    523. 

  523. <span class="sd">      target: The server address</span>
    524. 

  524. <span class="sd">      options: An optional list of key-value pairs (:term:`channel_arguments`</span>
    525. 

  525. <span class="sd">        in gRPC Core runtime) to configure the channel.</span>
    526. 

  526. <span class="sd">      compression: An optional value indicating the compression method to be</span>
    527. 

  527. <span class="sd">        used over the lifetime of the channel. This is an EXPERIMENTAL option.</span>
    528. 

  528. <span class="sd">      interceptors: An optional sequence of interceptors that will be executed for</span>
    529. 

  529. <span class="sd">        any call executed with this channel.</span>
    530. 

  530. 

  531. <span class="sd">    Returns:</span>
    532. 

  532. <span class="sd">      A Channel.</span>
    533. 

  533. <span class="sd">    &quot;&quot;&quot;</span>
    534. 

  534.     <span class="k">return</span> <span class="n">Channel</span><span class="p">(</span><span class="n">target</span><span class="p">,</span> <span class="p">()</span> <span class="k">if</span> <span class="n">options</span> <span class="ow">is</span> <span class="kc">None</span> <span class="k">else</span> <span class="n">options</span><span class="p">,</span> <span class="kc">None</span><span class="p">,</span>
    535. 

  535.                    <span class="n">compression</span><span class="p">,</span> <span class="n">interceptors</span><span class="p">)</span></div>
    536. 

  536. 

  537. 

  538. <div class="viewcode-block" id="secure_channel"><a class="viewcode-back" href="../../../../grpc_asyncio.html#grpc.experimental.aio.secure_channel">[docs]</a><span class="k">def</span> <span class="nf">secure_channel</span><span class="p">(</span><span class="n">target</span><span class="p">:</span> <span class="nb">str</span><span class="p">,</span>
    539. 

  539.                    <span class="n">credentials</span><span class="p">:</span> <span class="n">grpc</span><span class="o">.</span><span class="n">ChannelCredentials</span><span class="p">,</span>
    540. 

  540.                    <span class="n">options</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="n">ChannelArgumentType</span><span class="p">]</span> <span class="o">=</span> <span class="kc">None</span><span class="p">,</span>
    541. 

  541.                    <span class="n">compression</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="n">grpc</span><span class="o">.</span><span class="n">Compression</span><span class="p">]</span> <span class="o">=</span> <span class="kc">None</span><span class="p">,</span>
    542. 

  542.                    <span class="n">interceptors</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="n">Sequence</span><span class="p">[</span><span class="n">ClientInterceptor</span><span class="p">]]</span> <span class="o">=</span> <span class="kc">None</span><span class="p">):</span>
    543. 

  543.     <span class="sd">&quot;&quot;&quot;Creates a secure asynchronous Channel to a server.</span>
    544. 

  544. 

  545. <span class="sd">    Args:</span>
    546. 

  546. <span class="sd">      target: The server address.</span>
    547. 

  547. <span class="sd">      credentials: A ChannelCredentials instance.</span>
    548. 

  548. <span class="sd">      options: An optional list of key-value pairs (:term:`channel_arguments`</span>
    549. 

  549. <span class="sd">        in gRPC Core runtime) to configure the channel.</span>
    550. 

  550. <span class="sd">      compression: An optional value indicating the compression method to be</span>
    551. 

  551. <span class="sd">        used over the lifetime of the channel. This is an EXPERIMENTAL option.</span>
    552. 

  552. <span class="sd">      interceptors: An optional sequence of interceptors that will be executed for</span>
    553. 

  553. <span class="sd">        any call executed with this channel.</span>
    554. 

  554. 

  555. <span class="sd">    Returns:</span>
    556. 

  556. <span class="sd">      An aio.Channel.</span>
    557. 

  557. <span class="sd">    &quot;&quot;&quot;</span>
    558. 

  558.     <span class="k">return</span> <span class="n">Channel</span><span class="p">(</span><span class="n">target</span><span class="p">,</span> <span class="p">()</span> <span class="k">if</span> <span class="n">options</span> <span class="ow">is</span> <span class="kc">None</span> <span class="k">else</span> <span class="n">options</span><span class="p">,</span>
    559. 

  559.                    <span class="n">credentials</span><span class="o">.</span><span class="n">_credentials</span><span class="p">,</span> <span class="n">compression</span><span class="p">,</span> <span class="n">interceptors</span><span class="p">)</span></div>
    560. 

  560. </pre></div>
    561. 

  561. 

  562.           </div>
    563. 

  563.           
    564. 

  564.         </div>
    565. 

  565.       </div>
    566. 

  566.     <div class="clearer"></div>
    567. 

  567.   </div>
    568. 

  568.     <div class="footer">
    569. 

  569.       &copy;2020, The gRPC Authors.
    570. 

  570.       
    571. 

  571.     </div>
    572. 

  572. 

  573.     
    574. 

  574. 

  575.     
    576. 

  576.     <script type="text/javascript">
    577. 

  577. 

  578.       var _gaq = _gaq || [];
    579. 

  579.       _gaq.push(['_setAccount', 'UA-60127042-1']);
    580. 

  580.       _gaq.push(['_setDomainName', 'none']);
    581. 

  581.       _gaq.push(['_setAllowLinker', true]);
    582. 

  582.       _gaq.push(['_trackPageview']);
    583. 

  583. 

  584.       (function() {
    585. 

  585.         var ga = document.createElement('script'); ga.type = 'text/javascript'; ga.async = true;
    586. 

  586.         ga.src = ('https:' == document.location.protocol ? 'https://ssl' : 'http://www') + '.google-analytics.com/ga.js';
    587. 

  587.         var s = document.getElementsByTagName('script')[0]; s.parentNode.insertBefore(ga, s);
    588. 

  588.       })();
    589. 

  589. 

  590.     </script>
    591. 

  591.     
    592. 

  592.   </body>
    593. 

  593. </html>
    594.