|
@@ -8,7 +8,7 @@
|
|
|
|
|
|
<meta name="viewport" content="width=device-width, initial-scale=1.0">
|
|
|
|
|
|
- <title>grpc.framework.interfaces.face.face — grpcio 0.11.0b1 documentation</title>
|
|
|
+ <title>grpc.framework.interfaces.face.face — grpcio 0.13.1rc1 documentation</title>
|
|
|
|
|
|
|
|
|
|
|
@@ -30,7 +30,7 @@
|
|
|
|
|
|
|
|
|
|
|
|
- <link rel="top" title="grpcio 0.11.0b1 documentation" href="../../../../../index.html"/>
|
|
|
+ <link rel="top" title="grpcio 0.13.1rc1 documentation" href="../../../../../index.html"/>
|
|
|
<link rel="up" title="Module code" href="../../../../index.html"/>
|
|
|
|
|
|
|
|
@@ -59,7 +59,7 @@
|
|
|
|
|
|
|
|
|
<div class="version">
|
|
|
- 0.11.0b1
|
|
|
+ 0.13.1rc1
|
|
|
</div>
|
|
|
|
|
|
|
|
@@ -127,34 +127,34 @@
|
|
|
<div itemprop="articleBody">
|
|
|
|
|
|
<h1>Source code for grpc.framework.interfaces.face.face</h1><div class="highlight"><pre>
|
|
|
-<span class="c"># Copyright 2015, Google Inc.</span>
|
|
|
-<span class="c"># All rights reserved.</span>
|
|
|
-<span class="c">#</span>
|
|
|
-<span class="c"># Redistribution and use in source and binary forms, with or without</span>
|
|
|
-<span class="c"># modification, are permitted provided that the following conditions are</span>
|
|
|
-<span class="c"># met:</span>
|
|
|
-<span class="c">#</span>
|
|
|
-<span class="c"># * Redistributions of source code must retain the above copyright</span>
|
|
|
-<span class="c"># notice, this list of conditions and the following disclaimer.</span>
|
|
|
-<span class="c"># * Redistributions in binary form must reproduce the above</span>
|
|
|
-<span class="c"># copyright notice, this list of conditions and the following disclaimer</span>
|
|
|
-<span class="c"># in the documentation and/or other materials provided with the</span>
|
|
|
-<span class="c"># distribution.</span>
|
|
|
-<span class="c"># * Neither the name of Google Inc. nor the names of its</span>
|
|
|
-<span class="c"># contributors may be used to endorse or promote products derived from</span>
|
|
|
-<span class="c"># this software without specific prior written permission.</span>
|
|
|
-<span class="c">#</span>
|
|
|
-<span class="c"># THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS</span>
|
|
|
-<span class="c"># "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT</span>
|
|
|
-<span class="c"># LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR</span>
|
|
|
-<span class="c"># A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT</span>
|
|
|
-<span class="c"># OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,</span>
|
|
|
-<span class="c"># SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT</span>
|
|
|
-<span class="c"># LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,</span>
|
|
|
-<span class="c"># DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY</span>
|
|
|
-<span class="c"># THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT</span>
|
|
|
-<span class="c"># (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE</span>
|
|
|
-<span class="c"># OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.</span>
|
|
|
+<span></span><span class="c1"># Copyright 2015-2016, Google Inc.</span>
|
|
|
+<span class="c1"># All rights reserved.</span>
|
|
|
+<span class="c1">#</span>
|
|
|
+<span class="c1"># Redistribution and use in source and binary forms, with or without</span>
|
|
|
+<span class="c1"># modification, are permitted provided that the following conditions are</span>
|
|
|
+<span class="c1"># met:</span>
|
|
|
+<span class="c1">#</span>
|
|
|
+<span class="c1"># * Redistributions of source code must retain the above copyright</span>
|
|
|
+<span class="c1"># notice, this list of conditions and the following disclaimer.</span>
|
|
|
+<span class="c1"># * Redistributions in binary form must reproduce the above</span>
|
|
|
+<span class="c1"># copyright notice, this list of conditions and the following disclaimer</span>
|
|
|
+<span class="c1"># in the documentation and/or other materials provided with the</span>
|
|
|
+<span class="c1"># distribution.</span>
|
|
|
+<span class="c1"># * Neither the name of Google Inc. nor the names of its</span>
|
|
|
+<span class="c1"># contributors may be used to endorse or promote products derived from</span>
|
|
|
+<span class="c1"># this software without specific prior written permission.</span>
|
|
|
+<span class="c1">#</span>
|
|
|
+<span class="c1"># THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS</span>
|
|
|
+<span class="c1"># "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT</span>
|
|
|
+<span class="c1"># LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR</span>
|
|
|
+<span class="c1"># A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT</span>
|
|
|
+<span class="c1"># OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,</span>
|
|
|
+<span class="c1"># SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT</span>
|
|
|
+<span class="c1"># LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,</span>
|
|
|
+<span class="c1"># DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY</span>
|
|
|
+<span class="c1"># THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT</span>
|
|
|
+<span class="c1"># (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE</span>
|
|
|
+<span class="c1"># OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.</span>
|
|
|
|
|
|
<span class="sd">"""Interfaces defining the Face layer of RPC Framework."""</span>
|
|
|
|
|
@@ -162,13 +162,13 @@
|
|
|
<span class="kn">import</span> <span class="nn">collections</span>
|
|
|
<span class="kn">import</span> <span class="nn">enum</span>
|
|
|
|
|
|
-<span class="c"># cardinality, style, abandonment, future, and stream are</span>
|
|
|
-<span class="c"># referenced from specification in this module.</span>
|
|
|
-<span class="kn">from</span> <span class="nn">grpc.framework.common</span> <span class="kn">import</span> <span class="n">cardinality</span> <span class="c"># pylint: disable=unused-import</span>
|
|
|
-<span class="kn">from</span> <span class="nn">grpc.framework.common</span> <span class="kn">import</span> <span class="n">style</span> <span class="c"># pylint: disable=unused-import</span>
|
|
|
-<span class="kn">from</span> <span class="nn">grpc.framework.foundation</span> <span class="kn">import</span> <span class="n">abandonment</span> <span class="c"># pylint: disable=unused-import</span>
|
|
|
-<span class="kn">from</span> <span class="nn">grpc.framework.foundation</span> <span class="kn">import</span> <span class="n">future</span> <span class="c"># pylint: disable=unused-import</span>
|
|
|
-<span class="kn">from</span> <span class="nn">grpc.framework.foundation</span> <span class="kn">import</span> <span class="n">stream</span> <span class="c"># pylint: disable=unused-import</span>
|
|
|
+<span class="c1"># cardinality, style, abandonment, future, and stream are</span>
|
|
|
+<span class="c1"># referenced from specification in this module.</span>
|
|
|
+<span class="kn">from</span> <span class="nn">grpc.framework.common</span> <span class="k">import</span> <span class="n">cardinality</span> <span class="c1"># pylint: disable=unused-import</span>
|
|
|
+<span class="kn">from</span> <span class="nn">grpc.framework.common</span> <span class="k">import</span> <span class="n">style</span> <span class="c1"># pylint: disable=unused-import</span>
|
|
|
+<span class="kn">from</span> <span class="nn">grpc.framework.foundation</span> <span class="k">import</span> <span class="n">abandonment</span> <span class="c1"># pylint: disable=unused-import</span>
|
|
|
+<span class="kn">from</span> <span class="nn">grpc.framework.foundation</span> <span class="k">import</span> <span class="n">future</span> <span class="c1"># pylint: disable=unused-import</span>
|
|
|
+<span class="kn">from</span> <span class="nn">grpc.framework.foundation</span> <span class="k">import</span> <span class="n">stream</span> <span class="c1"># pylint: disable=unused-import</span>
|
|
|
|
|
|
|
|
|
<div class="viewcode-block" id="NoSuchMethodError"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.NoSuchMethodError">[docs]</a><span class="k">class</span> <span class="nc">NoSuchMethodError</span><span class="p">(</span><span class="ne">Exception</span><span class="p">):</span>
|
|
@@ -191,13 +191,13 @@
|
|
|
<span class="bp">self</span><span class="o">.</span><span class="n">method</span> <span class="o">=</span> <span class="n">method</span>
|
|
|
|
|
|
<span class="k">def</span> <span class="nf">__repr__</span><span class="p">(</span><span class="bp">self</span><span class="p">):</span>
|
|
|
- <span class="k">return</span> <span class="s">'face.NoSuchMethodError(</span><span class="si">%s</span><span class="s">, </span><span class="si">%s</span><span class="s">)'</span> <span class="o">%</span> <span class="p">(</span><span class="bp">self</span><span class="o">.</span><span class="n">group</span><span class="p">,</span> <span class="bp">self</span><span class="o">.</span><span class="n">method</span><span class="p">,)</span>
|
|
|
+ <span class="k">return</span> <span class="s1">'face.NoSuchMethodError(</span><span class="si">%s</span><span class="s1">, </span><span class="si">%s</span><span class="s1">)'</span> <span class="o">%</span> <span class="p">(</span><span class="bp">self</span><span class="o">.</span><span class="n">group</span><span class="p">,</span> <span class="bp">self</span><span class="o">.</span><span class="n">method</span><span class="p">,)</span></div>
|
|
|
+
|
|
|
|
|
|
-</div>
|
|
|
<div class="viewcode-block" id="Abortion"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.Abortion">[docs]</a><span class="k">class</span> <span class="nc">Abortion</span><span class="p">(</span>
|
|
|
<span class="n">collections</span><span class="o">.</span><span class="n">namedtuple</span><span class="p">(</span>
|
|
|
- <span class="s">'Abortion'</span><span class="p">,</span>
|
|
|
- <span class="p">(</span><span class="s">'kind'</span><span class="p">,</span> <span class="s">'initial_metadata'</span><span class="p">,</span> <span class="s">'terminal_metadata'</span><span class="p">,</span> <span class="s">'code'</span><span class="p">,</span> <span class="s">'details'</span><span class="p">,))):</span>
|
|
|
+ <span class="s1">'Abortion'</span><span class="p">,</span>
|
|
|
+ <span class="p">(</span><span class="s1">'kind'</span><span class="p">,</span> <span class="s1">'initial_metadata'</span><span class="p">,</span> <span class="s1">'terminal_metadata'</span><span class="p">,</span> <span class="s1">'code'</span><span class="p">,</span> <span class="s1">'details'</span><span class="p">,))):</span>
|
|
|
<span class="sd">"""A value describing RPC abortion.</span>
|
|
|
|
|
|
<span class="sd"> Attributes:</span>
|
|
@@ -212,19 +212,19 @@
|
|
|
<span class="sd"> details value was received.</span>
|
|
|
<span class="sd"> """</span>
|
|
|
|
|
|
- <span class="nd">@enum.unique</span>
|
|
|
+ <span class="nd">@enum</span><span class="o">.</span><span class="n">unique</span>
|
|
|
<div class="viewcode-block" id="Abortion.Kind"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.Abortion.Kind">[docs]</a> <span class="k">class</span> <span class="nc">Kind</span><span class="p">(</span><span class="n">enum</span><span class="o">.</span><span class="n">Enum</span><span class="p">):</span>
|
|
|
<span class="sd">"""Types of RPC abortion."""</span>
|
|
|
|
|
|
- <span class="n">CANCELLED</span> <span class="o">=</span> <span class="s">'cancelled'</span>
|
|
|
- <span class="n">EXPIRED</span> <span class="o">=</span> <span class="s">'expired'</span>
|
|
|
- <span class="n">LOCAL_SHUTDOWN</span> <span class="o">=</span> <span class="s">'local shutdown'</span>
|
|
|
- <span class="n">REMOTE_SHUTDOWN</span> <span class="o">=</span> <span class="s">'remote shutdown'</span>
|
|
|
- <span class="n">NETWORK_FAILURE</span> <span class="o">=</span> <span class="s">'network failure'</span>
|
|
|
- <span class="n">LOCAL_FAILURE</span> <span class="o">=</span> <span class="s">'local failure'</span>
|
|
|
- <span class="n">REMOTE_FAILURE</span> <span class="o">=</span> <span class="s">'remote failure'</span>
|
|
|
+ <span class="n">CANCELLED</span> <span class="o">=</span> <span class="s1">'cancelled'</span>
|
|
|
+ <span class="n">EXPIRED</span> <span class="o">=</span> <span class="s1">'expired'</span>
|
|
|
+ <span class="n">LOCAL_SHUTDOWN</span> <span class="o">=</span> <span class="s1">'local shutdown'</span>
|
|
|
+ <span class="n">REMOTE_SHUTDOWN</span> <span class="o">=</span> <span class="s1">'remote shutdown'</span>
|
|
|
+ <span class="n">NETWORK_FAILURE</span> <span class="o">=</span> <span class="s1">'network failure'</span>
|
|
|
+ <span class="n">LOCAL_FAILURE</span> <span class="o">=</span> <span class="s1">'local failure'</span>
|
|
|
+ <span class="n">REMOTE_FAILURE</span> <span class="o">=</span> <span class="s1">'remote failure'</span></div></div>
|
|
|
+
|
|
|
|
|
|
-</div></div>
|
|
|
<div class="viewcode-block" id="AbortionError"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.AbortionError">[docs]</a><span class="k">class</span> <span class="nc">AbortionError</span><span class="p">(</span><span class="ne">Exception</span><span class="p">):</span>
|
|
|
<span class="sd">"""Common super type for exceptions indicating RPC abortion.</span>
|
|
|
|
|
@@ -246,45 +246,49 @@
|
|
|
<span class="bp">self</span><span class="o">.</span><span class="n">code</span> <span class="o">=</span> <span class="n">code</span>
|
|
|
<span class="bp">self</span><span class="o">.</span><span class="n">details</span> <span class="o">=</span> <span class="n">details</span>
|
|
|
|
|
|
-</div>
|
|
|
+ <span class="k">def</span> <span class="nf">__str__</span><span class="p">(</span><span class="bp">self</span><span class="p">):</span>
|
|
|
+ <span class="k">return</span> <span class="s1">'</span><span class="si">%s</span><span class="s1">(code=</span><span class="si">%s</span><span class="s1">, details="</span><span class="si">%s</span><span class="s1">")'</span> <span class="o">%</span> <span class="p">(</span>
|
|
|
+ <span class="bp">self</span><span class="o">.</span><span class="n">__class__</span><span class="o">.</span><span class="n">__name__</span><span class="p">,</span> <span class="bp">self</span><span class="o">.</span><span class="n">code</span><span class="p">,</span> <span class="bp">self</span><span class="o">.</span><span class="n">details</span><span class="p">)</span></div>
|
|
|
+
|
|
|
+
|
|
|
<div class="viewcode-block" id="CancellationError"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.CancellationError">[docs]</a><span class="k">class</span> <span class="nc">CancellationError</span><span class="p">(</span><span class="n">AbortionError</span><span class="p">):</span>
|
|
|
- <span class="sd">"""Indicates that an RPC has been cancelled."""</span>
|
|
|
+ <span class="sd">"""Indicates that an RPC has been cancelled."""</span></div>
|
|
|
+
|
|
|
|
|
|
-</div>
|
|
|
<div class="viewcode-block" id="ExpirationError"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.ExpirationError">[docs]</a><span class="k">class</span> <span class="nc">ExpirationError</span><span class="p">(</span><span class="n">AbortionError</span><span class="p">):</span>
|
|
|
- <span class="sd">"""Indicates that an RPC has expired ("timed out")."""</span>
|
|
|
+ <span class="sd">"""Indicates that an RPC has expired ("timed out")."""</span></div>
|
|
|
+
|
|
|
|
|
|
-</div>
|
|
|
<div class="viewcode-block" id="LocalShutdownError"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.LocalShutdownError">[docs]</a><span class="k">class</span> <span class="nc">LocalShutdownError</span><span class="p">(</span><span class="n">AbortionError</span><span class="p">):</span>
|
|
|
- <span class="sd">"""Indicates that an RPC has terminated due to local shutdown of RPCs."""</span>
|
|
|
+ <span class="sd">"""Indicates that an RPC has terminated due to local shutdown of RPCs."""</span></div>
|
|
|
+
|
|
|
|
|
|
-</div>
|
|
|
<div class="viewcode-block" id="RemoteShutdownError"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.RemoteShutdownError">[docs]</a><span class="k">class</span> <span class="nc">RemoteShutdownError</span><span class="p">(</span><span class="n">AbortionError</span><span class="p">):</span>
|
|
|
- <span class="sd">"""Indicates that an RPC has terminated due to remote shutdown of RPCs."""</span>
|
|
|
+ <span class="sd">"""Indicates that an RPC has terminated due to remote shutdown of RPCs."""</span></div>
|
|
|
+
|
|
|
|
|
|
-</div>
|
|
|
<div class="viewcode-block" id="NetworkError"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.NetworkError">[docs]</a><span class="k">class</span> <span class="nc">NetworkError</span><span class="p">(</span><span class="n">AbortionError</span><span class="p">):</span>
|
|
|
- <span class="sd">"""Indicates that some error occurred on the network."""</span>
|
|
|
+ <span class="sd">"""Indicates that some error occurred on the network."""</span></div>
|
|
|
+
|
|
|
|
|
|
-</div>
|
|
|
<div class="viewcode-block" id="LocalError"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.LocalError">[docs]</a><span class="k">class</span> <span class="nc">LocalError</span><span class="p">(</span><span class="n">AbortionError</span><span class="p">):</span>
|
|
|
- <span class="sd">"""Indicates that an RPC has terminated due to a local defect."""</span>
|
|
|
+ <span class="sd">"""Indicates that an RPC has terminated due to a local defect."""</span></div>
|
|
|
+
|
|
|
|
|
|
-</div>
|
|
|
<div class="viewcode-block" id="RemoteError"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.RemoteError">[docs]</a><span class="k">class</span> <span class="nc">RemoteError</span><span class="p">(</span><span class="n">AbortionError</span><span class="p">):</span>
|
|
|
- <span class="sd">"""Indicates that an RPC has terminated due to a remote defect."""</span>
|
|
|
+ <span class="sd">"""Indicates that an RPC has terminated due to a remote defect."""</span></div>
|
|
|
+
|
|
|
|
|
|
-</div>
|
|
|
<div class="viewcode-block" id="RpcContext"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.RpcContext">[docs]</a><span class="k">class</span> <span class="nc">RpcContext</span><span class="p">(</span><span class="nb">object</span><span class="p">):</span>
|
|
|
<span class="sd">"""Provides RPC-related information and action."""</span>
|
|
|
<span class="n">__metaclass__</span> <span class="o">=</span> <span class="n">abc</span><span class="o">.</span><span class="n">ABCMeta</span>
|
|
|
|
|
|
- <span class="nd">@abc.abstractmethod</span>
|
|
|
+ <span class="nd">@abc</span><span class="o">.</span><span class="n">abstractmethod</span>
|
|
|
<div class="viewcode-block" id="RpcContext.is_active"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.RpcContext.is_active">[docs]</a> <span class="k">def</span> <span class="nf">is_active</span><span class="p">(</span><span class="bp">self</span><span class="p">):</span>
|
|
|
<span class="sd">"""Describes whether the RPC is active or has terminated."""</span>
|
|
|
- <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span>
|
|
|
-</div>
|
|
|
- <span class="nd">@abc.abstractmethod</span>
|
|
|
+ <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span></div>
|
|
|
+
|
|
|
+ <span class="nd">@abc</span><span class="o">.</span><span class="n">abstractmethod</span>
|
|
|
<div class="viewcode-block" id="RpcContext.time_remaining"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.RpcContext.time_remaining">[docs]</a> <span class="k">def</span> <span class="nf">time_remaining</span><span class="p">(</span><span class="bp">self</span><span class="p">):</span>
|
|
|
<span class="sd">"""Describes the length of allowed time remaining for the RPC.</span>
|
|
|
|
|
@@ -293,9 +297,9 @@
|
|
|
<span class="sd"> remaining for the RPC to complete before it is considered to have timed</span>
|
|
|
<span class="sd"> out.</span>
|
|
|
<span class="sd"> """</span>
|
|
|
- <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span>
|
|
|
-</div>
|
|
|
- <span class="nd">@abc.abstractmethod</span>
|
|
|
+ <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span></div>
|
|
|
+
|
|
|
+ <span class="nd">@abc</span><span class="o">.</span><span class="n">abstractmethod</span>
|
|
|
<div class="viewcode-block" id="RpcContext.add_abortion_callback"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.RpcContext.add_abortion_callback">[docs]</a> <span class="k">def</span> <span class="nf">add_abortion_callback</span><span class="p">(</span><span class="bp">self</span><span class="p">,</span> <span class="n">abortion_callback</span><span class="p">):</span>
|
|
|
<span class="sd">"""Registers a callback to be called if the RPC is aborted.</span>
|
|
|
|
|
@@ -303,17 +307,17 @@
|
|
|
<span class="sd"> abortion_callback: A callable to be called and passed an Abortion value</span>
|
|
|
<span class="sd"> in the event of RPC abortion.</span>
|
|
|
<span class="sd"> """</span>
|
|
|
- <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span>
|
|
|
-</div>
|
|
|
- <span class="nd">@abc.abstractmethod</span>
|
|
|
+ <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span></div>
|
|
|
+
|
|
|
+ <span class="nd">@abc</span><span class="o">.</span><span class="n">abstractmethod</span>
|
|
|
<div class="viewcode-block" id="RpcContext.cancel"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.RpcContext.cancel">[docs]</a> <span class="k">def</span> <span class="nf">cancel</span><span class="p">(</span><span class="bp">self</span><span class="p">):</span>
|
|
|
<span class="sd">"""Cancels the RPC.</span>
|
|
|
|
|
|
<span class="sd"> Idempotent and has no effect if the RPC has already terminated.</span>
|
|
|
<span class="sd"> """</span>
|
|
|
- <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span>
|
|
|
-</div>
|
|
|
- <span class="nd">@abc.abstractmethod</span>
|
|
|
+ <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span></div>
|
|
|
+
|
|
|
+ <span class="nd">@abc</span><span class="o">.</span><span class="n">abstractmethod</span>
|
|
|
<div class="viewcode-block" id="RpcContext.protocol_context"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.RpcContext.protocol_context">[docs]</a> <span class="k">def</span> <span class="nf">protocol_context</span><span class="p">(</span><span class="bp">self</span><span class="p">):</span>
|
|
|
<span class="sd">"""Accesses a custom object specified by an implementation provider.</span>
|
|
|
|
|
@@ -321,14 +325,14 @@
|
|
|
<span class="sd"> A value specified by the provider of a Face interface implementation</span>
|
|
|
<span class="sd"> affording custom state and behavior.</span>
|
|
|
<span class="sd"> """</span>
|
|
|
- <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span>
|
|
|
+ <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span></div></div>
|
|
|
+
|
|
|
|
|
|
-</div></div>
|
|
|
<div class="viewcode-block" id="Call"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.Call">[docs]</a><span class="k">class</span> <span class="nc">Call</span><span class="p">(</span><span class="n">RpcContext</span><span class="p">):</span>
|
|
|
<span class="sd">"""Invocation-side utility object for an RPC."""</span>
|
|
|
<span class="n">__metaclass__</span> <span class="o">=</span> <span class="n">abc</span><span class="o">.</span><span class="n">ABCMeta</span>
|
|
|
|
|
|
- <span class="nd">@abc.abstractmethod</span>
|
|
|
+ <span class="nd">@abc</span><span class="o">.</span><span class="n">abstractmethod</span>
|
|
|
<div class="viewcode-block" id="Call.initial_metadata"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.Call.initial_metadata">[docs]</a> <span class="k">def</span> <span class="nf">initial_metadata</span><span class="p">(</span><span class="bp">self</span><span class="p">):</span>
|
|
|
<span class="sd">"""Accesses the initial metadata from the service-side of the RPC.</span>
|
|
|
|
|
@@ -339,9 +343,9 @@
|
|
|
<span class="sd"> The initial metadata object emitted by the service-side of the RPC, or</span>
|
|
|
<span class="sd"> None if there was no such value.</span>
|
|
|
<span class="sd"> """</span>
|
|
|
- <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span>
|
|
|
-</div>
|
|
|
- <span class="nd">@abc.abstractmethod</span>
|
|
|
+ <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span></div>
|
|
|
+
|
|
|
+ <span class="nd">@abc</span><span class="o">.</span><span class="n">abstractmethod</span>
|
|
|
<div class="viewcode-block" id="Call.terminal_metadata"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.Call.terminal_metadata">[docs]</a> <span class="k">def</span> <span class="nf">terminal_metadata</span><span class="p">(</span><span class="bp">self</span><span class="p">):</span>
|
|
|
<span class="sd">"""Accesses the terminal metadata from the service-side of the RPC.</span>
|
|
|
|
|
@@ -352,9 +356,9 @@
|
|
|
<span class="sd"> The terminal metadata object emitted by the service-side of the RPC, or</span>
|
|
|
<span class="sd"> None if there was no such value.</span>
|
|
|
<span class="sd"> """</span>
|
|
|
- <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span>
|
|
|
-</div>
|
|
|
- <span class="nd">@abc.abstractmethod</span>
|
|
|
+ <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span></div>
|
|
|
+
|
|
|
+ <span class="nd">@abc</span><span class="o">.</span><span class="n">abstractmethod</span>
|
|
|
<div class="viewcode-block" id="Call.code"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.Call.code">[docs]</a> <span class="k">def</span> <span class="nf">code</span><span class="p">(</span><span class="bp">self</span><span class="p">):</span>
|
|
|
<span class="sd">"""Accesses the code emitted by the service-side of the RPC.</span>
|
|
|
|
|
@@ -365,9 +369,9 @@
|
|
|
<span class="sd"> The code object emitted by the service-side of the RPC, or None if there</span>
|
|
|
<span class="sd"> was no such value.</span>
|
|
|
<span class="sd"> """</span>
|
|
|
- <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span>
|
|
|
-</div>
|
|
|
- <span class="nd">@abc.abstractmethod</span>
|
|
|
+ <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span></div>
|
|
|
+
|
|
|
+ <span class="nd">@abc</span><span class="o">.</span><span class="n">abstractmethod</span>
|
|
|
<div class="viewcode-block" id="Call.details"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.Call.details">[docs]</a> <span class="k">def</span> <span class="nf">details</span><span class="p">(</span><span class="bp">self</span><span class="p">):</span>
|
|
|
<span class="sd">"""Accesses the details value emitted by the service-side of the RPC.</span>
|
|
|
|
|
@@ -378,14 +382,14 @@
|
|
|
<span class="sd"> The details value emitted by the service-side of the RPC, or None if there</span>
|
|
|
<span class="sd"> was no such value.</span>
|
|
|
<span class="sd"> """</span>
|
|
|
- <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span>
|
|
|
+ <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span></div></div>
|
|
|
+
|
|
|
|
|
|
-</div></div>
|
|
|
<div class="viewcode-block" id="ServicerContext"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.ServicerContext">[docs]</a><span class="k">class</span> <span class="nc">ServicerContext</span><span class="p">(</span><span class="n">RpcContext</span><span class="p">):</span>
|
|
|
<span class="sd">"""A context object passed to method implementations."""</span>
|
|
|
<span class="n">__metaclass__</span> <span class="o">=</span> <span class="n">abc</span><span class="o">.</span><span class="n">ABCMeta</span>
|
|
|
|
|
|
- <span class="nd">@abc.abstractmethod</span>
|
|
|
+ <span class="nd">@abc</span><span class="o">.</span><span class="n">abstractmethod</span>
|
|
|
<div class="viewcode-block" id="ServicerContext.invocation_metadata"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.ServicerContext.invocation_metadata">[docs]</a> <span class="k">def</span> <span class="nf">invocation_metadata</span><span class="p">(</span><span class="bp">self</span><span class="p">):</span>
|
|
|
<span class="sd">"""Accesses the metadata from the invocation-side of the RPC.</span>
|
|
|
|
|
@@ -396,9 +400,9 @@
|
|
|
<span class="sd"> The metadata object emitted by the invocation-side of the RPC, or None if</span>
|
|
|
<span class="sd"> there was no such value.</span>
|
|
|
<span class="sd"> """</span>
|
|
|
- <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span>
|
|
|
-</div>
|
|
|
- <span class="nd">@abc.abstractmethod</span>
|
|
|
+ <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span></div>
|
|
|
+
|
|
|
+ <span class="nd">@abc</span><span class="o">.</span><span class="n">abstractmethod</span>
|
|
|
<div class="viewcode-block" id="ServicerContext.initial_metadata"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.ServicerContext.initial_metadata">[docs]</a> <span class="k">def</span> <span class="nf">initial_metadata</span><span class="p">(</span><span class="bp">self</span><span class="p">,</span> <span class="n">initial_metadata</span><span class="p">):</span>
|
|
|
<span class="sd">"""Accepts the service-side initial metadata value of the RPC.</span>
|
|
|
|
|
@@ -409,9 +413,9 @@
|
|
|
<span class="sd"> initial_metadata: The service-side initial metadata value of the RPC to</span>
|
|
|
<span class="sd"> be transmitted to the invocation side of the RPC.</span>
|
|
|
<span class="sd"> """</span>
|
|
|
- <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span>
|
|
|
-</div>
|
|
|
- <span class="nd">@abc.abstractmethod</span>
|
|
|
+ <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span></div>
|
|
|
+
|
|
|
+ <span class="nd">@abc</span><span class="o">.</span><span class="n">abstractmethod</span>
|
|
|
<div class="viewcode-block" id="ServicerContext.terminal_metadata"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.ServicerContext.terminal_metadata">[docs]</a> <span class="k">def</span> <span class="nf">terminal_metadata</span><span class="p">(</span><span class="bp">self</span><span class="p">,</span> <span class="n">terminal_metadata</span><span class="p">):</span>
|
|
|
<span class="sd">"""Accepts the service-side terminal metadata value of the RPC.</span>
|
|
|
|
|
@@ -422,9 +426,9 @@
|
|
|
<span class="sd"> terminal_metadata: The service-side terminal metadata value of the RPC to</span>
|
|
|
<span class="sd"> be transmitted to the invocation side of the RPC.</span>
|
|
|
<span class="sd"> """</span>
|
|
|
- <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span>
|
|
|
-</div>
|
|
|
- <span class="nd">@abc.abstractmethod</span>
|
|
|
+ <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span></div>
|
|
|
+
|
|
|
+ <span class="nd">@abc</span><span class="o">.</span><span class="n">abstractmethod</span>
|
|
|
<div class="viewcode-block" id="ServicerContext.code"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.ServicerContext.code">[docs]</a> <span class="k">def</span> <span class="nf">code</span><span class="p">(</span><span class="bp">self</span><span class="p">,</span> <span class="n">code</span><span class="p">):</span>
|
|
|
<span class="sd">"""Accepts the service-side code of the RPC.</span>
|
|
|
|
|
@@ -435,9 +439,9 @@
|
|
|
<span class="sd"> code: The code of the RPC to be transmitted to the invocation side of the</span>
|
|
|
<span class="sd"> RPC.</span>
|
|
|
<span class="sd"> """</span>
|
|
|
- <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span>
|
|
|
-</div>
|
|
|
- <span class="nd">@abc.abstractmethod</span>
|
|
|
+ <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span></div>
|
|
|
+
|
|
|
+ <span class="nd">@abc</span><span class="o">.</span><span class="n">abstractmethod</span>
|
|
|
<div class="viewcode-block" id="ServicerContext.details"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.ServicerContext.details">[docs]</a> <span class="k">def</span> <span class="nf">details</span><span class="p">(</span><span class="bp">self</span><span class="p">,</span> <span class="n">details</span><span class="p">):</span>
|
|
|
<span class="sd">"""Accepts the service-side details of the RPC.</span>
|
|
|
|
|
@@ -448,14 +452,14 @@
|
|
|
<span class="sd"> details: The service-side details value of the RPC to be transmitted to</span>
|
|
|
<span class="sd"> the invocation side of the RPC.</span>
|
|
|
<span class="sd"> """</span>
|
|
|
- <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span>
|
|
|
+ <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span></div></div>
|
|
|
+
|
|
|
|
|
|
-</div></div>
|
|
|
<div class="viewcode-block" id="ResponseReceiver"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.ResponseReceiver">[docs]</a><span class="k">class</span> <span class="nc">ResponseReceiver</span><span class="p">(</span><span class="nb">object</span><span class="p">):</span>
|
|
|
<span class="sd">"""Invocation-side object used to accept the output of an RPC."""</span>
|
|
|
<span class="n">__metaclass__</span> <span class="o">=</span> <span class="n">abc</span><span class="o">.</span><span class="n">ABCMeta</span>
|
|
|
|
|
|
- <span class="nd">@abc.abstractmethod</span>
|
|
|
+ <span class="nd">@abc</span><span class="o">.</span><span class="n">abstractmethod</span>
|
|
|
<div class="viewcode-block" id="ResponseReceiver.initial_metadata"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.ResponseReceiver.initial_metadata">[docs]</a> <span class="k">def</span> <span class="nf">initial_metadata</span><span class="p">(</span><span class="bp">self</span><span class="p">,</span> <span class="n">initial_metadata</span><span class="p">):</span>
|
|
|
<span class="sd">"""Receives the initial metadata from the service-side of the RPC.</span>
|
|
|
|
|
@@ -463,18 +467,18 @@
|
|
|
<span class="sd"> initial_metadata: The initial metadata object emitted from the</span>
|
|
|
<span class="sd"> service-side of the RPC.</span>
|
|
|
<span class="sd"> """</span>
|
|
|
- <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span>
|
|
|
-</div>
|
|
|
- <span class="nd">@abc.abstractmethod</span>
|
|
|
+ <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span></div>
|
|
|
+
|
|
|
+ <span class="nd">@abc</span><span class="o">.</span><span class="n">abstractmethod</span>
|
|
|
<div class="viewcode-block" id="ResponseReceiver.response"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.ResponseReceiver.response">[docs]</a> <span class="k">def</span> <span class="nf">response</span><span class="p">(</span><span class="bp">self</span><span class="p">,</span> <span class="n">response</span><span class="p">):</span>
|
|
|
<span class="sd">"""Receives a response from the service-side of the RPC.</span>
|
|
|
|
|
|
<span class="sd"> Args:</span>
|
|
|
<span class="sd"> response: A response object emitted from the service-side of the RPC.</span>
|
|
|
<span class="sd"> """</span>
|
|
|
- <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span>
|
|
|
-</div>
|
|
|
- <span class="nd">@abc.abstractmethod</span>
|
|
|
+ <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span></div>
|
|
|
+
|
|
|
+ <span class="nd">@abc</span><span class="o">.</span><span class="n">abstractmethod</span>
|
|
|
<div class="viewcode-block" id="ResponseReceiver.complete"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.ResponseReceiver.complete">[docs]</a> <span class="k">def</span> <span class="nf">complete</span><span class="p">(</span><span class="bp">self</span><span class="p">,</span> <span class="n">terminal_metadata</span><span class="p">,</span> <span class="n">code</span><span class="p">,</span> <span class="n">details</span><span class="p">):</span>
|
|
|
<span class="sd">"""Receives the completion values emitted from the service-side of the RPC.</span>
|
|
|
|
|
@@ -484,17 +488,17 @@
|
|
|
<span class="sd"> code: The code object emitted from the service-side of the RPC.</span>
|
|
|
<span class="sd"> details: The details object emitted from the service-side of the RPC.</span>
|
|
|
<span class="sd"> """</span>
|
|
|
- <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span>
|
|
|
+ <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span></div></div>
|
|
|
+
|
|
|
|
|
|
-</div></div>
|
|
|
<div class="viewcode-block" id="UnaryUnaryMultiCallable"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.UnaryUnaryMultiCallable">[docs]</a><span class="k">class</span> <span class="nc">UnaryUnaryMultiCallable</span><span class="p">(</span><span class="nb">object</span><span class="p">):</span>
|
|
|
<span class="sd">"""Affords invoking a unary-unary RPC in any call style."""</span>
|
|
|
<span class="n">__metaclass__</span> <span class="o">=</span> <span class="n">abc</span><span class="o">.</span><span class="n">ABCMeta</span>
|
|
|
|
|
|
- <span class="nd">@abc.abstractmethod</span>
|
|
|
-<div class="viewcode-block" id="UnaryUnaryMultiCallable.__call__"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.UnaryUnaryMultiCallable.__call__">[docs]</a> <span class="k">def</span> <span class="nf">__call__</span><span class="p">(</span>
|
|
|
- <span class="bp">self</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="o">=</span><span class="bp">None</span><span class="p">,</span> <span class="n">with_call</span><span class="o">=</span><span class="bp">False</span><span class="p">,</span>
|
|
|
- <span class="n">protocol_options</span><span class="o">=</span><span class="bp">None</span><span class="p">):</span>
|
|
|
+ <span class="nd">@abc</span><span class="o">.</span><span class="n">abstractmethod</span>
|
|
|
+ <span class="k">def</span> <span class="nf">__call__</span><span class="p">(</span>
|
|
|
+ <span class="bp">self</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="o">=</span><span class="kc">None</span><span class="p">,</span> <span class="n">with_call</span><span class="o">=</span><span class="kc">False</span><span class="p">,</span>
|
|
|
+ <span class="n">protocol_options</span><span class="o">=</span><span class="kc">None</span><span class="p">):</span>
|
|
|
<span class="sd">"""Synchronously invokes the underlying RPC.</span>
|
|
|
|
|
|
<span class="sd"> Args:</span>
|
|
@@ -503,7 +507,7 @@
|
|
|
<span class="sd"> metadata: A metadata value to be passed to the service-side of</span>
|
|
|
<span class="sd"> the RPC.</span>
|
|
|
<span class="sd"> with_call: Whether or not to include return a Call for the RPC in addition</span>
|
|
|
-<span class="sd"> to the reponse.</span>
|
|
|
+<span class="sd"> to the response.</span>
|
|
|
<span class="sd"> protocol_options: A value specified by the provider of a Face interface</span>
|
|
|
<span class="sd"> implementation affording custom state and behavior.</span>
|
|
|
|
|
@@ -515,9 +519,9 @@
|
|
|
<span class="sd"> AbortionError: Indicating that the RPC was aborted.</span>
|
|
|
<span class="sd"> """</span>
|
|
|
<span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span>
|
|
|
-</div>
|
|
|
- <span class="nd">@abc.abstractmethod</span>
|
|
|
-<div class="viewcode-block" id="UnaryUnaryMultiCallable.future"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.UnaryUnaryMultiCallable.future">[docs]</a> <span class="k">def</span> <span class="nf">future</span><span class="p">(</span><span class="bp">self</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="o">=</span><span class="bp">None</span><span class="p">,</span> <span class="n">protocol_options</span><span class="o">=</span><span class="bp">None</span><span class="p">):</span>
|
|
|
+
|
|
|
+ <span class="nd">@abc</span><span class="o">.</span><span class="n">abstractmethod</span>
|
|
|
+<div class="viewcode-block" id="UnaryUnaryMultiCallable.future"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.UnaryUnaryMultiCallable.future">[docs]</a> <span class="k">def</span> <span class="nf">future</span><span class="p">(</span><span class="bp">self</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="o">=</span><span class="kc">None</span><span class="p">,</span> <span class="n">protocol_options</span><span class="o">=</span><span class="kc">None</span><span class="p">):</span>
|
|
|
<span class="sd">"""Asynchronously invokes the underlying RPC.</span>
|
|
|
|
|
|
<span class="sd"> Args:</span>
|
|
@@ -534,12 +538,12 @@
|
|
|
<span class="sd"> response value of the RPC. In the event of RPC abortion, the returned</span>
|
|
|
<span class="sd"> Future's exception value will be an AbortionError.</span>
|
|
|
<span class="sd"> """</span>
|
|
|
- <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span>
|
|
|
-</div>
|
|
|
- <span class="nd">@abc.abstractmethod</span>
|
|
|
+ <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span></div>
|
|
|
+
|
|
|
+ <span class="nd">@abc</span><span class="o">.</span><span class="n">abstractmethod</span>
|
|
|
<div class="viewcode-block" id="UnaryUnaryMultiCallable.event"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.UnaryUnaryMultiCallable.event">[docs]</a> <span class="k">def</span> <span class="nf">event</span><span class="p">(</span>
|
|
|
<span class="bp">self</span><span class="p">,</span> <span class="n">request</span><span class="p">,</span> <span class="n">receiver</span><span class="p">,</span> <span class="n">abortion_callback</span><span class="p">,</span> <span class="n">timeout</span><span class="p">,</span>
|
|
|
- <span class="n">metadata</span><span class="o">=</span><span class="bp">None</span><span class="p">,</span> <span class="n">protocol_options</span><span class="o">=</span><span class="bp">None</span><span class="p">):</span>
|
|
|
+ <span class="n">metadata</span><span class="o">=</span><span class="kc">None</span><span class="p">,</span> <span class="n">protocol_options</span><span class="o">=</span><span class="kc">None</span><span class="p">):</span>
|
|
|
<span class="sd">"""Asynchronously invokes the underlying RPC.</span>
|
|
|
|
|
|
<span class="sd"> Args:</span>
|
|
@@ -556,15 +560,15 @@
|
|
|
<span class="sd"> Returns:</span>
|
|
|
<span class="sd"> A Call for the RPC.</span>
|
|
|
<span class="sd"> """</span>
|
|
|
- <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span>
|
|
|
+ <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span></div></div>
|
|
|
+
|
|
|
|
|
|
-</div></div>
|
|
|
<div class="viewcode-block" id="UnaryStreamMultiCallable"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.UnaryStreamMultiCallable">[docs]</a><span class="k">class</span> <span class="nc">UnaryStreamMultiCallable</span><span class="p">(</span><span class="nb">object</span><span class="p">):</span>
|
|
|
<span class="sd">"""Affords invoking a unary-stream RPC in any call style."""</span>
|
|
|
<span class="n">__metaclass__</span> <span class="o">=</span> <span class="n">abc</span><span class="o">.</span><span class="n">ABCMeta</span>
|
|
|
|
|
|
- <span class="nd">@abc.abstractmethod</span>
|
|
|
-<div class="viewcode-block" id="UnaryStreamMultiCallable.__call__"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.UnaryStreamMultiCallable.__call__">[docs]</a> <span class="k">def</span> <span class="nf">__call__</span><span class="p">(</span><span class="bp">self</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="o">=</span><span class="bp">None</span><span class="p">,</span> <span class="n">protocol_options</span><span class="o">=</span><span class="bp">None</span><span class="p">):</span>
|
|
|
+ <span class="nd">@abc</span><span class="o">.</span><span class="n">abstractmethod</span>
|
|
|
+ <span class="k">def</span> <span class="nf">__call__</span><span class="p">(</span><span class="bp">self</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="o">=</span><span class="kc">None</span><span class="p">,</span> <span class="n">protocol_options</span><span class="o">=</span><span class="kc">None</span><span class="p">):</span>
|
|
|
<span class="sd">"""Invokes the underlying RPC.</span>
|
|
|
|
|
|
<span class="sd"> Args:</span>
|
|
@@ -581,11 +585,11 @@
|
|
|
<span class="sd"> AbortionError indicating abortion of the RPC.</span>
|
|
|
<span class="sd"> """</span>
|
|
|
<span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span>
|
|
|
-</div>
|
|
|
- <span class="nd">@abc.abstractmethod</span>
|
|
|
+
|
|
|
+ <span class="nd">@abc</span><span class="o">.</span><span class="n">abstractmethod</span>
|
|
|
<div class="viewcode-block" id="UnaryStreamMultiCallable.event"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.UnaryStreamMultiCallable.event">[docs]</a> <span class="k">def</span> <span class="nf">event</span><span class="p">(</span>
|
|
|
<span class="bp">self</span><span class="p">,</span> <span class="n">request</span><span class="p">,</span> <span class="n">receiver</span><span class="p">,</span> <span class="n">abortion_callback</span><span class="p">,</span> <span class="n">timeout</span><span class="p">,</span>
|
|
|
- <span class="n">metadata</span><span class="o">=</span><span class="bp">None</span><span class="p">,</span> <span class="n">protocol_options</span><span class="o">=</span><span class="bp">None</span><span class="p">):</span>
|
|
|
+ <span class="n">metadata</span><span class="o">=</span><span class="kc">None</span><span class="p">,</span> <span class="n">protocol_options</span><span class="o">=</span><span class="kc">None</span><span class="p">):</span>
|
|
|
<span class="sd">"""Asynchronously invokes the underlying RPC.</span>
|
|
|
|
|
|
<span class="sd"> Args:</span>
|
|
@@ -602,17 +606,17 @@
|
|
|
<span class="sd"> Returns:</span>
|
|
|
<span class="sd"> A Call object for the RPC.</span>
|
|
|
<span class="sd"> """</span>
|
|
|
- <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span>
|
|
|
+ <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span></div></div>
|
|
|
+
|
|
|
|
|
|
-</div></div>
|
|
|
<div class="viewcode-block" id="StreamUnaryMultiCallable"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.StreamUnaryMultiCallable">[docs]</a><span class="k">class</span> <span class="nc">StreamUnaryMultiCallable</span><span class="p">(</span><span class="nb">object</span><span class="p">):</span>
|
|
|
<span class="sd">"""Affords invoking a stream-unary RPC in any call style."""</span>
|
|
|
<span class="n">__metaclass__</span> <span class="o">=</span> <span class="n">abc</span><span class="o">.</span><span class="n">ABCMeta</span>
|
|
|
|
|
|
- <span class="nd">@abc.abstractmethod</span>
|
|
|
-<div class="viewcode-block" id="StreamUnaryMultiCallable.__call__"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.StreamUnaryMultiCallable.__call__">[docs]</a> <span class="k">def</span> <span class="nf">__call__</span><span class="p">(</span>
|
|
|
- <span class="bp">self</span><span class="p">,</span> <span class="n">request_iterator</span><span class="p">,</span> <span class="n">timeout</span><span class="p">,</span> <span class="n">metadata</span><span class="o">=</span><span class="bp">None</span><span class="p">,</span>
|
|
|
- <span class="n">with_call</span><span class="o">=</span><span class="bp">False</span><span class="p">,</span> <span class="n">protocol_options</span><span class="o">=</span><span class="bp">None</span><span class="p">):</span>
|
|
|
+ <span class="nd">@abc</span><span class="o">.</span><span class="n">abstractmethod</span>
|
|
|
+ <span class="k">def</span> <span class="nf">__call__</span><span class="p">(</span>
|
|
|
+ <span class="bp">self</span><span class="p">,</span> <span class="n">request_iterator</span><span class="p">,</span> <span class="n">timeout</span><span class="p">,</span> <span class="n">metadata</span><span class="o">=</span><span class="kc">None</span><span class="p">,</span>
|
|
|
+ <span class="n">with_call</span><span class="o">=</span><span class="kc">False</span><span class="p">,</span> <span class="n">protocol_options</span><span class="o">=</span><span class="kc">None</span><span class="p">):</span>
|
|
|
<span class="sd">"""Synchronously invokes the underlying RPC.</span>
|
|
|
|
|
|
<span class="sd"> Args:</span>
|
|
@@ -621,7 +625,7 @@
|
|
|
<span class="sd"> metadata: A metadata value to be passed to the service-side of</span>
|
|
|
<span class="sd"> the RPC.</span>
|
|
|
<span class="sd"> with_call: Whether or not to include return a Call for the RPC in addition</span>
|
|
|
-<span class="sd"> to the reponse.</span>
|
|
|
+<span class="sd"> to the response.</span>
|
|
|
<span class="sd"> protocol_options: A value specified by the provider of a Face interface</span>
|
|
|
<span class="sd"> implementation affording custom state and behavior.</span>
|
|
|
|
|
@@ -633,10 +637,10 @@
|
|
|
<span class="sd"> AbortionError: Indicating that the RPC was aborted.</span>
|
|
|
<span class="sd"> """</span>
|
|
|
<span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span>
|
|
|
-</div>
|
|
|
- <span class="nd">@abc.abstractmethod</span>
|
|
|
+
|
|
|
+ <span class="nd">@abc</span><span class="o">.</span><span class="n">abstractmethod</span>
|
|
|
<div class="viewcode-block" id="StreamUnaryMultiCallable.future"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.StreamUnaryMultiCallable.future">[docs]</a> <span class="k">def</span> <span class="nf">future</span><span class="p">(</span>
|
|
|
- <span class="bp">self</span><span class="p">,</span> <span class="n">request_iterator</span><span class="p">,</span> <span class="n">timeout</span><span class="p">,</span> <span class="n">metadata</span><span class="o">=</span><span class="bp">None</span><span class="p">,</span> <span class="n">protocol_options</span><span class="o">=</span><span class="bp">None</span><span class="p">):</span>
|
|
|
+ <span class="bp">self</span><span class="p">,</span> <span class="n">request_iterator</span><span class="p">,</span> <span class="n">timeout</span><span class="p">,</span> <span class="n">metadata</span><span class="o">=</span><span class="kc">None</span><span class="p">,</span> <span class="n">protocol_options</span><span class="o">=</span><span class="kc">None</span><span class="p">):</span>
|
|
|
<span class="sd">"""Asynchronously invokes the underlying RPC.</span>
|
|
|
|
|
|
<span class="sd"> Args:</span>
|
|
@@ -653,12 +657,12 @@
|
|
|
<span class="sd"> response value of the RPC. In the event of RPC abortion, the returned</span>
|
|
|
<span class="sd"> Future's exception value will be an AbortionError.</span>
|
|
|
<span class="sd"> """</span>
|
|
|
- <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span>
|
|
|
-</div>
|
|
|
- <span class="nd">@abc.abstractmethod</span>
|
|
|
+ <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span></div>
|
|
|
+
|
|
|
+ <span class="nd">@abc</span><span class="o">.</span><span class="n">abstractmethod</span>
|
|
|
<div class="viewcode-block" id="StreamUnaryMultiCallable.event"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.StreamUnaryMultiCallable.event">[docs]</a> <span class="k">def</span> <span class="nf">event</span><span class="p">(</span>
|
|
|
- <span class="bp">self</span><span class="p">,</span> <span class="n">receiver</span><span class="p">,</span> <span class="n">abortion_callback</span><span class="p">,</span> <span class="n">timeout</span><span class="p">,</span> <span class="n">metadata</span><span class="o">=</span><span class="bp">None</span><span class="p">,</span>
|
|
|
- <span class="n">protocol_options</span><span class="o">=</span><span class="bp">None</span><span class="p">):</span>
|
|
|
+ <span class="bp">self</span><span class="p">,</span> <span class="n">receiver</span><span class="p">,</span> <span class="n">abortion_callback</span><span class="p">,</span> <span class="n">timeout</span><span class="p">,</span> <span class="n">metadata</span><span class="o">=</span><span class="kc">None</span><span class="p">,</span>
|
|
|
+ <span class="n">protocol_options</span><span class="o">=</span><span class="kc">None</span><span class="p">):</span>
|
|
|
<span class="sd">"""Asynchronously invokes the underlying RPC.</span>
|
|
|
|
|
|
<span class="sd"> Args:</span>
|
|
@@ -675,16 +679,16 @@
|
|
|
<span class="sd"> A single object that is both a Call object for the RPC and a</span>
|
|
|
<span class="sd"> stream.Consumer to which the request values of the RPC should be passed.</span>
|
|
|
<span class="sd"> """</span>
|
|
|
- <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span>
|
|
|
+ <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span></div></div>
|
|
|
+
|
|
|
|
|
|
-</div></div>
|
|
|
<div class="viewcode-block" id="StreamStreamMultiCallable"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.StreamStreamMultiCallable">[docs]</a><span class="k">class</span> <span class="nc">StreamStreamMultiCallable</span><span class="p">(</span><span class="nb">object</span><span class="p">):</span>
|
|
|
<span class="sd">"""Affords invoking a stream-stream RPC in any call style."""</span>
|
|
|
<span class="n">__metaclass__</span> <span class="o">=</span> <span class="n">abc</span><span class="o">.</span><span class="n">ABCMeta</span>
|
|
|
|
|
|
- <span class="nd">@abc.abstractmethod</span>
|
|
|
-<div class="viewcode-block" id="StreamStreamMultiCallable.__call__"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.StreamStreamMultiCallable.__call__">[docs]</a> <span class="k">def</span> <span class="nf">__call__</span><span class="p">(</span>
|
|
|
- <span class="bp">self</span><span class="p">,</span> <span class="n">request_iterator</span><span class="p">,</span> <span class="n">timeout</span><span class="p">,</span> <span class="n">metadata</span><span class="o">=</span><span class="bp">None</span><span class="p">,</span> <span class="n">protocol_options</span><span class="o">=</span><span class="bp">None</span><span class="p">):</span>
|
|
|
+ <span class="nd">@abc</span><span class="o">.</span><span class="n">abstractmethod</span>
|
|
|
+ <span class="k">def</span> <span class="nf">__call__</span><span class="p">(</span>
|
|
|
+ <span class="bp">self</span><span class="p">,</span> <span class="n">request_iterator</span><span class="p">,</span> <span class="n">timeout</span><span class="p">,</span> <span class="n">metadata</span><span class="o">=</span><span class="kc">None</span><span class="p">,</span> <span class="n">protocol_options</span><span class="o">=</span><span class="kc">None</span><span class="p">):</span>
|
|
|
<span class="sd">"""Invokes the underlying RPC.</span>
|
|
|
|
|
|
<span class="sd"> Args:</span>
|
|
@@ -701,11 +705,11 @@
|
|
|
<span class="sd"> AbortionError indicating abortion of the RPC.</span>
|
|
|
<span class="sd"> """</span>
|
|
|
<span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span>
|
|
|
-</div>
|
|
|
- <span class="nd">@abc.abstractmethod</span>
|
|
|
+
|
|
|
+ <span class="nd">@abc</span><span class="o">.</span><span class="n">abstractmethod</span>
|
|
|
<div class="viewcode-block" id="StreamStreamMultiCallable.event"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.StreamStreamMultiCallable.event">[docs]</a> <span class="k">def</span> <span class="nf">event</span><span class="p">(</span>
|
|
|
- <span class="bp">self</span><span class="p">,</span> <span class="n">receiver</span><span class="p">,</span> <span class="n">abortion_callback</span><span class="p">,</span> <span class="n">timeout</span><span class="p">,</span> <span class="n">metadata</span><span class="o">=</span><span class="bp">None</span><span class="p">,</span>
|
|
|
- <span class="n">protocol_options</span><span class="o">=</span><span class="bp">None</span><span class="p">):</span>
|
|
|
+ <span class="bp">self</span><span class="p">,</span> <span class="n">receiver</span><span class="p">,</span> <span class="n">abortion_callback</span><span class="p">,</span> <span class="n">timeout</span><span class="p">,</span> <span class="n">metadata</span><span class="o">=</span><span class="kc">None</span><span class="p">,</span>
|
|
|
+ <span class="n">protocol_options</span><span class="o">=</span><span class="kc">None</span><span class="p">):</span>
|
|
|
<span class="sd">"""Asynchronously invokes the underlying RPC.</span>
|
|
|
|
|
|
<span class="sd"> Args:</span>
|
|
@@ -722,9 +726,9 @@
|
|
|
<span class="sd"> A single object that is both a Call object for the RPC and a</span>
|
|
|
<span class="sd"> stream.Consumer to which the request values of the RPC should be passed.</span>
|
|
|
<span class="sd"> """</span>
|
|
|
- <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span>
|
|
|
+ <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span></div></div>
|
|
|
+
|
|
|
|
|
|
-</div></div>
|
|
|
<div class="viewcode-block" id="MethodImplementation"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.MethodImplementation">[docs]</a><span class="k">class</span> <span class="nc">MethodImplementation</span><span class="p">(</span><span class="nb">object</span><span class="p">):</span>
|
|
|
<span class="sd">"""A sum type that describes a method implementation.</span>
|
|
|
|
|
@@ -768,14 +772,14 @@
|
|
|
<span class="sd"> is cardinality.Cardinality.STREAM_STREAM and style is</span>
|
|
|
<span class="sd"> style.Service.EVENT.</span>
|
|
|
<span class="sd"> """</span>
|
|
|
- <span class="n">__metaclass__</span> <span class="o">=</span> <span class="n">abc</span><span class="o">.</span><span class="n">ABCMeta</span>
|
|
|
+ <span class="n">__metaclass__</span> <span class="o">=</span> <span class="n">abc</span><span class="o">.</span><span class="n">ABCMeta</span></div>
|
|
|
+
|
|
|
|
|
|
-</div>
|
|
|
<div class="viewcode-block" id="MultiMethodImplementation"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.MultiMethodImplementation">[docs]</a><span class="k">class</span> <span class="nc">MultiMethodImplementation</span><span class="p">(</span><span class="nb">object</span><span class="p">):</span>
|
|
|
<span class="sd">"""A general type able to service many methods."""</span>
|
|
|
<span class="n">__metaclass__</span> <span class="o">=</span> <span class="n">abc</span><span class="o">.</span><span class="n">ABCMeta</span>
|
|
|
|
|
|
- <span class="nd">@abc.abstractmethod</span>
|
|
|
+ <span class="nd">@abc</span><span class="o">.</span><span class="n">abstractmethod</span>
|
|
|
<div class="viewcode-block" id="MultiMethodImplementation.service"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.MultiMethodImplementation.service">[docs]</a> <span class="k">def</span> <span class="nf">service</span><span class="p">(</span><span class="bp">self</span><span class="p">,</span> <span class="n">group</span><span class="p">,</span> <span class="n">method</span><span class="p">,</span> <span class="n">response_consumer</span><span class="p">,</span> <span class="n">context</span><span class="p">):</span>
|
|
|
<span class="sd">"""Services an RPC.</span>
|
|
|
|
|
@@ -800,17 +804,17 @@
|
|
|
<span class="sd"> NoSuchMethodError: If this MultiMethod does not recognize the given group</span>
|
|
|
<span class="sd"> and name for the RPC and is not able to service the RPC.</span>
|
|
|
<span class="sd"> """</span>
|
|
|
- <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span>
|
|
|
+ <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span></div></div>
|
|
|
+
|
|
|
|
|
|
-</div></div>
|
|
|
<div class="viewcode-block" id="GenericStub"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.GenericStub">[docs]</a><span class="k">class</span> <span class="nc">GenericStub</span><span class="p">(</span><span class="nb">object</span><span class="p">):</span>
|
|
|
<span class="sd">"""Affords RPC invocation via generic methods."""</span>
|
|
|
<span class="n">__metaclass__</span> <span class="o">=</span> <span class="n">abc</span><span class="o">.</span><span class="n">ABCMeta</span>
|
|
|
|
|
|
- <span class="nd">@abc.abstractmethod</span>
|
|
|
+ <span class="nd">@abc</span><span class="o">.</span><span class="n">abstractmethod</span>
|
|
|
<div class="viewcode-block" id="GenericStub.blocking_unary_unary"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.GenericStub.blocking_unary_unary">[docs]</a> <span class="k">def</span> <span class="nf">blocking_unary_unary</span><span class="p">(</span>
|
|
|
- <span class="bp">self</span><span class="p">,</span> <span class="n">group</span><span class="p">,</span> <span class="n">method</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="o">=</span><span class="bp">None</span><span class="p">,</span>
|
|
|
- <span class="n">with_call</span><span class="o">=</span><span class="bp">False</span><span class="p">,</span> <span class="n">protocol_options</span><span class="o">=</span><span class="bp">None</span><span class="p">):</span>
|
|
|
+ <span class="bp">self</span><span class="p">,</span> <span class="n">group</span><span class="p">,</span> <span class="n">method</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="o">=</span><span class="kc">None</span><span class="p">,</span>
|
|
|
+ <span class="n">with_call</span><span class="o">=</span><span class="kc">False</span><span class="p">,</span> <span class="n">protocol_options</span><span class="o">=</span><span class="kc">None</span><span class="p">):</span>
|
|
|
<span class="sd">"""Invokes a unary-request-unary-response method.</span>
|
|
|
|
|
|
<span class="sd"> This method blocks until either returning the response value of the RPC</span>
|
|
@@ -824,7 +828,7 @@
|
|
|
<span class="sd"> timeout: A duration of time in seconds to allow for the RPC.</span>
|
|
|
<span class="sd"> metadata: A metadata value to be passed to the service-side of the RPC.</span>
|
|
|
<span class="sd"> with_call: Whether or not to include return a Call for the RPC in addition</span>
|
|
|
-<span class="sd"> to the reponse.</span>
|
|
|
+<span class="sd"> to the response.</span>
|
|
|
<span class="sd"> protocol_options: A value specified by the provider of a Face interface</span>
|
|
|
<span class="sd"> implementation affording custom state and behavior.</span>
|
|
|
|
|
@@ -835,12 +839,12 @@
|
|
|
<span class="sd"> Raises:</span>
|
|
|
<span class="sd"> AbortionError: Indicating that the RPC was aborted.</span>
|
|
|
<span class="sd"> """</span>
|
|
|
- <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span>
|
|
|
-</div>
|
|
|
- <span class="nd">@abc.abstractmethod</span>
|
|
|
+ <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span></div>
|
|
|
+
|
|
|
+ <span class="nd">@abc</span><span class="o">.</span><span class="n">abstractmethod</span>
|
|
|
<div class="viewcode-block" id="GenericStub.future_unary_unary"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.GenericStub.future_unary_unary">[docs]</a> <span class="k">def</span> <span class="nf">future_unary_unary</span><span class="p">(</span>
|
|
|
- <span class="bp">self</span><span class="p">,</span> <span class="n">group</span><span class="p">,</span> <span class="n">method</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="o">=</span><span class="bp">None</span><span class="p">,</span>
|
|
|
- <span class="n">protocol_options</span><span class="o">=</span><span class="bp">None</span><span class="p">):</span>
|
|
|
+ <span class="bp">self</span><span class="p">,</span> <span class="n">group</span><span class="p">,</span> <span class="n">method</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="o">=</span><span class="kc">None</span><span class="p">,</span>
|
|
|
+ <span class="n">protocol_options</span><span class="o">=</span><span class="kc">None</span><span class="p">):</span>
|
|
|
<span class="sd">"""Invokes a unary-request-unary-response method.</span>
|
|
|
|
|
|
<span class="sd"> Args:</span>
|
|
@@ -858,12 +862,12 @@
|
|
|
<span class="sd"> response value of the RPC. In the event of RPC abortion, the returned</span>
|
|
|
<span class="sd"> Future's exception value will be an AbortionError.</span>
|
|
|
<span class="sd"> """</span>
|
|
|
- <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span>
|
|
|
-</div>
|
|
|
- <span class="nd">@abc.abstractmethod</span>
|
|
|
+ <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span></div>
|
|
|
+
|
|
|
+ <span class="nd">@abc</span><span class="o">.</span><span class="n">abstractmethod</span>
|
|
|
<div class="viewcode-block" id="GenericStub.inline_unary_stream"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.GenericStub.inline_unary_stream">[docs]</a> <span class="k">def</span> <span class="nf">inline_unary_stream</span><span class="p">(</span>
|
|
|
- <span class="bp">self</span><span class="p">,</span> <span class="n">group</span><span class="p">,</span> <span class="n">method</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="o">=</span><span class="bp">None</span><span class="p">,</span>
|
|
|
- <span class="n">protocol_options</span><span class="o">=</span><span class="bp">None</span><span class="p">):</span>
|
|
|
+ <span class="bp">self</span><span class="p">,</span> <span class="n">group</span><span class="p">,</span> <span class="n">method</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="o">=</span><span class="kc">None</span><span class="p">,</span>
|
|
|
+ <span class="n">protocol_options</span><span class="o">=</span><span class="kc">None</span><span class="p">):</span>
|
|
|
<span class="sd">"""Invokes a unary-request-stream-response method.</span>
|
|
|
|
|
|
<span class="sd"> Args:</span>
|
|
@@ -880,12 +884,12 @@
|
|
|
<span class="sd"> values. Drawing response values from the returned iterator may raise</span>
|
|
|
<span class="sd"> AbortionError indicating abortion of the RPC.</span>
|
|
|
<span class="sd"> """</span>
|
|
|
- <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span>
|
|
|
-</div>
|
|
|
- <span class="nd">@abc.abstractmethod</span>
|
|
|
+ <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span></div>
|
|
|
+
|
|
|
+ <span class="nd">@abc</span><span class="o">.</span><span class="n">abstractmethod</span>
|
|
|
<div class="viewcode-block" id="GenericStub.blocking_stream_unary"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.GenericStub.blocking_stream_unary">[docs]</a> <span class="k">def</span> <span class="nf">blocking_stream_unary</span><span class="p">(</span>
|
|
|
- <span class="bp">self</span><span class="p">,</span> <span class="n">group</span><span class="p">,</span> <span class="n">method</span><span class="p">,</span> <span class="n">request_iterator</span><span class="p">,</span> <span class="n">timeout</span><span class="p">,</span> <span class="n">metadata</span><span class="o">=</span><span class="bp">None</span><span class="p">,</span>
|
|
|
- <span class="n">with_call</span><span class="o">=</span><span class="bp">False</span><span class="p">,</span> <span class="n">protocol_options</span><span class="o">=</span><span class="bp">None</span><span class="p">):</span>
|
|
|
+ <span class="bp">self</span><span class="p">,</span> <span class="n">group</span><span class="p">,</span> <span class="n">method</span><span class="p">,</span> <span class="n">request_iterator</span><span class="p">,</span> <span class="n">timeout</span><span class="p">,</span> <span class="n">metadata</span><span class="o">=</span><span class="kc">None</span><span class="p">,</span>
|
|
|
+ <span class="n">with_call</span><span class="o">=</span><span class="kc">False</span><span class="p">,</span> <span class="n">protocol_options</span><span class="o">=</span><span class="kc">None</span><span class="p">):</span>
|
|
|
<span class="sd">"""Invokes a stream-request-unary-response method.</span>
|
|
|
|
|
|
<span class="sd"> This method blocks until either returning the response value of the RPC</span>
|
|
@@ -899,7 +903,7 @@
|
|
|
<span class="sd"> timeout: A duration of time in seconds to allow for the RPC.</span>
|
|
|
<span class="sd"> metadata: A metadata value to be passed to the service-side of the RPC.</span>
|
|
|
<span class="sd"> with_call: Whether or not to include return a Call for the RPC in addition</span>
|
|
|
-<span class="sd"> to the reponse.</span>
|
|
|
+<span class="sd"> to the response.</span>
|
|
|
<span class="sd"> protocol_options: A value specified by the provider of a Face interface</span>
|
|
|
<span class="sd"> implementation affording custom state and behavior.</span>
|
|
|
|
|
@@ -910,12 +914,12 @@
|
|
|
<span class="sd"> Raises:</span>
|
|
|
<span class="sd"> AbortionError: Indicating that the RPC was aborted.</span>
|
|
|
<span class="sd"> """</span>
|
|
|
- <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span>
|
|
|
-</div>
|
|
|
- <span class="nd">@abc.abstractmethod</span>
|
|
|
+ <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span></div>
|
|
|
+
|
|
|
+ <span class="nd">@abc</span><span class="o">.</span><span class="n">abstractmethod</span>
|
|
|
<div class="viewcode-block" id="GenericStub.future_stream_unary"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.GenericStub.future_stream_unary">[docs]</a> <span class="k">def</span> <span class="nf">future_stream_unary</span><span class="p">(</span>
|
|
|
- <span class="bp">self</span><span class="p">,</span> <span class="n">group</span><span class="p">,</span> <span class="n">method</span><span class="p">,</span> <span class="n">request_iterator</span><span class="p">,</span> <span class="n">timeout</span><span class="p">,</span> <span class="n">metadata</span><span class="o">=</span><span class="bp">None</span><span class="p">,</span>
|
|
|
- <span class="n">protocol_options</span><span class="o">=</span><span class="bp">None</span><span class="p">):</span>
|
|
|
+ <span class="bp">self</span><span class="p">,</span> <span class="n">group</span><span class="p">,</span> <span class="n">method</span><span class="p">,</span> <span class="n">request_iterator</span><span class="p">,</span> <span class="n">timeout</span><span class="p">,</span> <span class="n">metadata</span><span class="o">=</span><span class="kc">None</span><span class="p">,</span>
|
|
|
+ <span class="n">protocol_options</span><span class="o">=</span><span class="kc">None</span><span class="p">):</span>
|
|
|
<span class="sd">"""Invokes a stream-request-unary-response method.</span>
|
|
|
|
|
|
<span class="sd"> Args:</span>
|
|
@@ -933,12 +937,12 @@
|
|
|
<span class="sd"> response value of the RPC. In the event of RPC abortion, the returned</span>
|
|
|
<span class="sd"> Future's exception value will be an AbortionError.</span>
|
|
|
<span class="sd"> """</span>
|
|
|
- <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span>
|
|
|
-</div>
|
|
|
- <span class="nd">@abc.abstractmethod</span>
|
|
|
+ <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span></div>
|
|
|
+
|
|
|
+ <span class="nd">@abc</span><span class="o">.</span><span class="n">abstractmethod</span>
|
|
|
<div class="viewcode-block" id="GenericStub.inline_stream_stream"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.GenericStub.inline_stream_stream">[docs]</a> <span class="k">def</span> <span class="nf">inline_stream_stream</span><span class="p">(</span>
|
|
|
- <span class="bp">self</span><span class="p">,</span> <span class="n">group</span><span class="p">,</span> <span class="n">method</span><span class="p">,</span> <span class="n">request_iterator</span><span class="p">,</span> <span class="n">timeout</span><span class="p">,</span> <span class="n">metadata</span><span class="o">=</span><span class="bp">None</span><span class="p">,</span>
|
|
|
- <span class="n">protocol_options</span><span class="o">=</span><span class="bp">None</span><span class="p">):</span>
|
|
|
+ <span class="bp">self</span><span class="p">,</span> <span class="n">group</span><span class="p">,</span> <span class="n">method</span><span class="p">,</span> <span class="n">request_iterator</span><span class="p">,</span> <span class="n">timeout</span><span class="p">,</span> <span class="n">metadata</span><span class="o">=</span><span class="kc">None</span><span class="p">,</span>
|
|
|
+ <span class="n">protocol_options</span><span class="o">=</span><span class="kc">None</span><span class="p">):</span>
|
|
|
<span class="sd">"""Invokes a stream-request-stream-response method.</span>
|
|
|
|
|
|
<span class="sd"> Args:</span>
|
|
@@ -955,12 +959,12 @@
|
|
|
<span class="sd"> values. Drawing response values from the returned iterator may raise</span>
|
|
|
<span class="sd"> AbortionError indicating abortion of the RPC.</span>
|
|
|
<span class="sd"> """</span>
|
|
|
- <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span>
|
|
|
-</div>
|
|
|
- <span class="nd">@abc.abstractmethod</span>
|
|
|
+ <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span></div>
|
|
|
+
|
|
|
+ <span class="nd">@abc</span><span class="o">.</span><span class="n">abstractmethod</span>
|
|
|
<div class="viewcode-block" id="GenericStub.event_unary_unary"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.GenericStub.event_unary_unary">[docs]</a> <span class="k">def</span> <span class="nf">event_unary_unary</span><span class="p">(</span>
|
|
|
<span class="bp">self</span><span class="p">,</span> <span class="n">group</span><span class="p">,</span> <span class="n">method</span><span class="p">,</span> <span class="n">request</span><span class="p">,</span> <span class="n">receiver</span><span class="p">,</span> <span class="n">abortion_callback</span><span class="p">,</span> <span class="n">timeout</span><span class="p">,</span>
|
|
|
- <span class="n">metadata</span><span class="o">=</span><span class="bp">None</span><span class="p">,</span> <span class="n">protocol_options</span><span class="o">=</span><span class="bp">None</span><span class="p">):</span>
|
|
|
+ <span class="n">metadata</span><span class="o">=</span><span class="kc">None</span><span class="p">,</span> <span class="n">protocol_options</span><span class="o">=</span><span class="kc">None</span><span class="p">):</span>
|
|
|
<span class="sd">"""Event-driven invocation of a unary-request-unary-response method.</span>
|
|
|
|
|
|
<span class="sd"> Args:</span>
|
|
@@ -978,12 +982,12 @@
|
|
|
<span class="sd"> Returns:</span>
|
|
|
<span class="sd"> A Call for the RPC.</span>
|
|
|
<span class="sd"> """</span>
|
|
|
- <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span>
|
|
|
-</div>
|
|
|
- <span class="nd">@abc.abstractmethod</span>
|
|
|
+ <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span></div>
|
|
|
+
|
|
|
+ <span class="nd">@abc</span><span class="o">.</span><span class="n">abstractmethod</span>
|
|
|
<div class="viewcode-block" id="GenericStub.event_unary_stream"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.GenericStub.event_unary_stream">[docs]</a> <span class="k">def</span> <span class="nf">event_unary_stream</span><span class="p">(</span>
|
|
|
<span class="bp">self</span><span class="p">,</span> <span class="n">group</span><span class="p">,</span> <span class="n">method</span><span class="p">,</span> <span class="n">request</span><span class="p">,</span> <span class="n">receiver</span><span class="p">,</span> <span class="n">abortion_callback</span><span class="p">,</span> <span class="n">timeout</span><span class="p">,</span>
|
|
|
- <span class="n">metadata</span><span class="o">=</span><span class="bp">None</span><span class="p">,</span> <span class="n">protocol_options</span><span class="o">=</span><span class="bp">None</span><span class="p">):</span>
|
|
|
+ <span class="n">metadata</span><span class="o">=</span><span class="kc">None</span><span class="p">,</span> <span class="n">protocol_options</span><span class="o">=</span><span class="kc">None</span><span class="p">):</span>
|
|
|
<span class="sd">"""Event-driven invocation of a unary-request-stream-response method.</span>
|
|
|
|
|
|
<span class="sd"> Args:</span>
|
|
@@ -1001,12 +1005,12 @@
|
|
|
<span class="sd"> Returns:</span>
|
|
|
<span class="sd"> A Call for the RPC.</span>
|
|
|
<span class="sd"> """</span>
|
|
|
- <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span>
|
|
|
-</div>
|
|
|
- <span class="nd">@abc.abstractmethod</span>
|
|
|
+ <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span></div>
|
|
|
+
|
|
|
+ <span class="nd">@abc</span><span class="o">.</span><span class="n">abstractmethod</span>
|
|
|
<div class="viewcode-block" id="GenericStub.event_stream_unary"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.GenericStub.event_stream_unary">[docs]</a> <span class="k">def</span> <span class="nf">event_stream_unary</span><span class="p">(</span>
|
|
|
<span class="bp">self</span><span class="p">,</span> <span class="n">group</span><span class="p">,</span> <span class="n">method</span><span class="p">,</span> <span class="n">receiver</span><span class="p">,</span> <span class="n">abortion_callback</span><span class="p">,</span> <span class="n">timeout</span><span class="p">,</span>
|
|
|
- <span class="n">metadata</span><span class="o">=</span><span class="bp">None</span><span class="p">,</span> <span class="n">protocol_options</span><span class="o">=</span><span class="bp">None</span><span class="p">):</span>
|
|
|
+ <span class="n">metadata</span><span class="o">=</span><span class="kc">None</span><span class="p">,</span> <span class="n">protocol_options</span><span class="o">=</span><span class="kc">None</span><span class="p">):</span>
|
|
|
<span class="sd">"""Event-driven invocation of a unary-request-unary-response method.</span>
|
|
|
|
|
|
<span class="sd"> Args:</span>
|
|
@@ -1024,12 +1028,12 @@
|
|
|
<span class="sd"> A pair of a Call object for the RPC and a stream.Consumer to which the</span>
|
|
|
<span class="sd"> request values of the RPC should be passed.</span>
|
|
|
<span class="sd"> """</span>
|
|
|
- <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span>
|
|
|
-</div>
|
|
|
- <span class="nd">@abc.abstractmethod</span>
|
|
|
+ <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span></div>
|
|
|
+
|
|
|
+ <span class="nd">@abc</span><span class="o">.</span><span class="n">abstractmethod</span>
|
|
|
<div class="viewcode-block" id="GenericStub.event_stream_stream"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.GenericStub.event_stream_stream">[docs]</a> <span class="k">def</span> <span class="nf">event_stream_stream</span><span class="p">(</span>
|
|
|
<span class="bp">self</span><span class="p">,</span> <span class="n">group</span><span class="p">,</span> <span class="n">method</span><span class="p">,</span> <span class="n">receiver</span><span class="p">,</span> <span class="n">abortion_callback</span><span class="p">,</span> <span class="n">timeout</span><span class="p">,</span>
|
|
|
- <span class="n">metadata</span><span class="o">=</span><span class="bp">None</span><span class="p">,</span> <span class="n">protocol_options</span><span class="o">=</span><span class="bp">None</span><span class="p">):</span>
|
|
|
+ <span class="n">metadata</span><span class="o">=</span><span class="kc">None</span><span class="p">,</span> <span class="n">protocol_options</span><span class="o">=</span><span class="kc">None</span><span class="p">):</span>
|
|
|
<span class="sd">"""Event-driven invocation of a unary-request-stream-response method.</span>
|
|
|
|
|
|
<span class="sd"> Args:</span>
|
|
@@ -1047,9 +1051,9 @@
|
|
|
<span class="sd"> A pair of a Call object for the RPC and a stream.Consumer to which the</span>
|
|
|
<span class="sd"> request values of the RPC should be passed.</span>
|
|
|
<span class="sd"> """</span>
|
|
|
- <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span>
|
|
|
-</div>
|
|
|
- <span class="nd">@abc.abstractmethod</span>
|
|
|
+ <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span></div>
|
|
|
+
|
|
|
+ <span class="nd">@abc</span><span class="o">.</span><span class="n">abstractmethod</span>
|
|
|
<div class="viewcode-block" id="GenericStub.unary_unary"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.GenericStub.unary_unary">[docs]</a> <span class="k">def</span> <span class="nf">unary_unary</span><span class="p">(</span><span class="bp">self</span><span class="p">,</span> <span class="n">group</span><span class="p">,</span> <span class="n">method</span><span class="p">):</span>
|
|
|
<span class="sd">"""Creates a UnaryUnaryMultiCallable for a unary-unary method.</span>
|
|
|
|
|
@@ -1060,9 +1064,9 @@
|
|
|
<span class="sd"> Returns:</span>
|
|
|
<span class="sd"> A UnaryUnaryMultiCallable value for the named unary-unary method.</span>
|
|
|
<span class="sd"> """</span>
|
|
|
- <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span>
|
|
|
-</div>
|
|
|
- <span class="nd">@abc.abstractmethod</span>
|
|
|
+ <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span></div>
|
|
|
+
|
|
|
+ <span class="nd">@abc</span><span class="o">.</span><span class="n">abstractmethod</span>
|
|
|
<div class="viewcode-block" id="GenericStub.unary_stream"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.GenericStub.unary_stream">[docs]</a> <span class="k">def</span> <span class="nf">unary_stream</span><span class="p">(</span><span class="bp">self</span><span class="p">,</span> <span class="n">group</span><span class="p">,</span> <span class="n">method</span><span class="p">):</span>
|
|
|
<span class="sd">"""Creates a UnaryStreamMultiCallable for a unary-stream method.</span>
|
|
|
|
|
@@ -1073,9 +1077,9 @@
|
|
|
<span class="sd"> Returns:</span>
|
|
|
<span class="sd"> A UnaryStreamMultiCallable value for the name unary-stream method.</span>
|
|
|
<span class="sd"> """</span>
|
|
|
- <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span>
|
|
|
-</div>
|
|
|
- <span class="nd">@abc.abstractmethod</span>
|
|
|
+ <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span></div>
|
|
|
+
|
|
|
+ <span class="nd">@abc</span><span class="o">.</span><span class="n">abstractmethod</span>
|
|
|
<div class="viewcode-block" id="GenericStub.stream_unary"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.GenericStub.stream_unary">[docs]</a> <span class="k">def</span> <span class="nf">stream_unary</span><span class="p">(</span><span class="bp">self</span><span class="p">,</span> <span class="n">group</span><span class="p">,</span> <span class="n">method</span><span class="p">):</span>
|
|
|
<span class="sd">"""Creates a StreamUnaryMultiCallable for a stream-unary method.</span>
|
|
|
|
|
@@ -1086,9 +1090,9 @@
|
|
|
<span class="sd"> Returns:</span>
|
|
|
<span class="sd"> A StreamUnaryMultiCallable value for the named stream-unary method.</span>
|
|
|
<span class="sd"> """</span>
|
|
|
- <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span>
|
|
|
-</div>
|
|
|
- <span class="nd">@abc.abstractmethod</span>
|
|
|
+ <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span></div>
|
|
|
+
|
|
|
+ <span class="nd">@abc</span><span class="o">.</span><span class="n">abstractmethod</span>
|
|
|
<div class="viewcode-block" id="GenericStub.stream_stream"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.GenericStub.stream_stream">[docs]</a> <span class="k">def</span> <span class="nf">stream_stream</span><span class="p">(</span><span class="bp">self</span><span class="p">,</span> <span class="n">group</span><span class="p">,</span> <span class="n">method</span><span class="p">):</span>
|
|
|
<span class="sd">"""Creates a StreamStreamMultiCallable for a stream-stream method.</span>
|
|
|
|
|
@@ -1099,9 +1103,9 @@
|
|
|
<span class="sd"> Returns:</span>
|
|
|
<span class="sd"> A StreamStreamMultiCallable value for the named stream-stream method.</span>
|
|
|
<span class="sd"> """</span>
|
|
|
- <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span>
|
|
|
+ <span class="k">raise</span> <span class="ne">NotImplementedError</span><span class="p">()</span></div></div>
|
|
|
+
|
|
|
|
|
|
-</div></div>
|
|
|
<div class="viewcode-block" id="DynamicStub"><a class="viewcode-back" href="../../../../../grpc.framework.interfaces.face.html#grpc.framework.interfaces.face.face.DynamicStub">[docs]</a><span class="k">class</span> <span class="nc">DynamicStub</span><span class="p">(</span><span class="nb">object</span><span class="p">):</span>
|
|
|
<span class="sd">"""Affords RPC invocation via attributes corresponding to afforded methods.</span>
|
|
|
|
|
@@ -1130,7 +1134,7 @@
|
|
|
|
|
|
<div role="contentinfo">
|
|
|
<p>
|
|
|
- © Copyright 2015, Author.
|
|
|
+ © Copyright 2016, Author.
|
|
|
|
|
|
</p>
|
|
|
</div>
|
|
@@ -1152,7 +1156,7 @@
|
|
|
<script type="text/javascript">
|
|
|
var DOCUMENTATION_OPTIONS = {
|
|
|
URL_ROOT:'../../../../../',
|
|
|
- VERSION:'0.11.0b1',
|
|
|
+ VERSION:'0.13.1rc1',
|
|
|
COLLAPSE_INDEX:false,
|
|
|
FILE_SUFFIX:'.html',
|
|
|
HAS_SOURCE: true
|