impl_2codegen_2async__stream_8h_source.html 106 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599
  1. <!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">
  2. <html xmlns="http://www.w3.org/1999/xhtml">
  3. <head>
  4. <meta http-equiv="Content-Type" content="text/xhtml;charset=UTF-8"/>
  5. <meta http-equiv="X-UA-Compatible" content="IE=9"/>
  6. <meta name="generator" content="Doxygen 1.8.6"/>
  7. <title>GRPC C++: include/grpc++/impl/codegen/async_stream.h Source File</title>
  8. <link href="tabs.css" rel="stylesheet" type="text/css"/>
  9. <script type="text/javascript" src="jquery.js"></script>
  10. <script type="text/javascript" src="dynsections.js"></script>
  11. <link href="search/search.css" rel="stylesheet" type="text/css"/>
  12. <script type="text/javascript" src="search/search.js"></script>
  13. <script type="text/javascript">
  14. $(document).ready(function() { searchBox.OnSelectItem(0); });
  15. </script>
  16. <link href="doxygen.css" rel="stylesheet" type="text/css" />
  17. </head>
  18. <body>
  19. <div id="top"><!-- do not remove this div, it is closed by doxygen! -->
  20. <div id="titlearea">
  21. <table cellspacing="0" cellpadding="0">
  22. <tbody>
  23. <tr style="height: 56px;">
  24. <td style="padding-left: 0.5em;">
  25. <div id="projectname">GRPC C++
  26. &#160;<span id="projectnumber">0.13.1-pre1</span>
  27. </div>
  28. </td>
  29. </tr>
  30. </tbody>
  31. </table>
  32. </div>
  33. <!-- end header part -->
  34. <!-- Generated by Doxygen 1.8.6 -->
  35. <script type="text/javascript">
  36. var searchBox = new SearchBox("searchBox", "search",false,'Search');
  37. </script>
  38. <div id="navrow1" class="tabs">
  39. <ul class="tablist">
  40. <li><a href="index.html"><span>Main&#160;Page</span></a></li>
  41. <li><a href="namespaces.html"><span>Namespaces</span></a></li>
  42. <li><a href="annotated.html"><span>Data&#160;Structures</span></a></li>
  43. <li class="current"><a href="files.html"><span>Files</span></a></li>
  44. <li>
  45. <div id="MSearchBox" class="MSearchBoxInactive">
  46. <span class="left">
  47. <img id="MSearchSelect" src="search/mag_sel.png"
  48. onmouseover="return searchBox.OnSearchSelectShow()"
  49. onmouseout="return searchBox.OnSearchSelectHide()"
  50. alt=""/>
  51. <input type="text" id="MSearchField" value="Search" accesskey="S"
  52. onfocus="searchBox.OnSearchFieldFocus(true)"
  53. onblur="searchBox.OnSearchFieldFocus(false)"
  54. onkeyup="searchBox.OnSearchFieldChange(event)"/>
  55. </span><span class="right">
  56. <a id="MSearchClose" href="javascript:searchBox.CloseResultsWindow()"><img id="MSearchCloseImg" border="0" src="search/close.png" alt=""/></a>
  57. </span>
  58. </div>
  59. </li>
  60. </ul>
  61. </div>
  62. <div id="navrow2" class="tabs2">
  63. <ul class="tablist">
  64. <li><a href="files.html"><span>File&#160;List</span></a></li>
  65. <li><a href="globals.html"><span>Globals</span></a></li>
  66. </ul>
  67. </div>
  68. <!-- window showing the filter options -->
  69. <div id="MSearchSelectWindow"
  70. onmouseover="return searchBox.OnSearchSelectShow()"
  71. onmouseout="return searchBox.OnSearchSelectHide()"
  72. onkeydown="return searchBox.OnSearchSelectKey(event)">
  73. <a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(0)"><span class="SelectionMark">&#160;</span>All</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(1)"><span class="SelectionMark">&#160;</span>Data Structures</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(2)"><span class="SelectionMark">&#160;</span>Namespaces</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(3)"><span class="SelectionMark">&#160;</span>Files</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(4)"><span class="SelectionMark">&#160;</span>Functions</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(5)"><span class="SelectionMark">&#160;</span>Variables</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(6)"><span class="SelectionMark">&#160;</span>Typedefs</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(7)"><span class="SelectionMark">&#160;</span>Enumerations</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(8)"><span class="SelectionMark">&#160;</span>Enumerator</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(9)"><span class="SelectionMark">&#160;</span>Friends</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(10)"><span class="SelectionMark">&#160;</span>Macros</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(11)"><span class="SelectionMark">&#160;</span>Pages</a></div>
  74. <!-- iframe showing the search results (closed by default) -->
  75. <div id="MSearchResultsWindow">
  76. <iframe src="javascript:void(0)" frameborder="0"
  77. name="MSearchResults" id="MSearchResults">
  78. </iframe>
  79. </div>
  80. <div id="nav-path" class="navpath">
  81. <ul>
  82. <li class="navelem"><a class="el" href="dir_d44c64559bbebec7f509842c48db8b23.html">include</a></li><li class="navelem"><a class="el" href="dir_f1b2ab2a88927c1e950e43c1cf4b634b.html">grpc++</a></li><li class="navelem"><a class="el" href="dir_ac8b245a5921095c43c106649fd7bc4b.html">impl</a></li><li class="navelem"><a class="el" href="dir_a7c29f91546e182c0f2b46e2e51819eb.html">codegen</a></li> </ul>
  83. </div>
  84. </div><!-- top -->
  85. <div class="header">
  86. <div class="headertitle">
  87. <div class="title">async_stream.h</div> </div>
  88. </div><!--header-->
  89. <div class="contents">
  90. <a href="impl_2codegen_2async__stream_8h.html">Go to the documentation of this file.</a><div class="fragment"><div class="line"><a name="l00001"></a><span class="lineno"> 1</span>&#160;<span class="comment">/*</span></div>
  91. <div class="line"><a name="l00002"></a><span class="lineno"> 2</span>&#160;<span class="comment"> *</span></div>
  92. <div class="line"><a name="l00003"></a><span class="lineno"> 3</span>&#160;<span class="comment"> * Copyright 2015-2016, Google Inc.</span></div>
  93. <div class="line"><a name="l00004"></a><span class="lineno"> 4</span>&#160;<span class="comment"> * All rights reserved.</span></div>
  94. <div class="line"><a name="l00005"></a><span class="lineno"> 5</span>&#160;<span class="comment"> *</span></div>
  95. <div class="line"><a name="l00006"></a><span class="lineno"> 6</span>&#160;<span class="comment"> * Redistribution and use in source and binary forms, with or without</span></div>
  96. <div class="line"><a name="l00007"></a><span class="lineno"> 7</span>&#160;<span class="comment"> * modification, are permitted provided that the following conditions are</span></div>
  97. <div class="line"><a name="l00008"></a><span class="lineno"> 8</span>&#160;<span class="comment"> * met:</span></div>
  98. <div class="line"><a name="l00009"></a><span class="lineno"> 9</span>&#160;<span class="comment"> *</span></div>
  99. <div class="line"><a name="l00010"></a><span class="lineno"> 10</span>&#160;<span class="comment"> * * Redistributions of source code must retain the above copyright</span></div>
  100. <div class="line"><a name="l00011"></a><span class="lineno"> 11</span>&#160;<span class="comment"> * notice, this list of conditions and the following disclaimer.</span></div>
  101. <div class="line"><a name="l00012"></a><span class="lineno"> 12</span>&#160;<span class="comment"> * * Redistributions in binary form must reproduce the above</span></div>
  102. <div class="line"><a name="l00013"></a><span class="lineno"> 13</span>&#160;<span class="comment"> * copyright notice, this list of conditions and the following disclaimer</span></div>
  103. <div class="line"><a name="l00014"></a><span class="lineno"> 14</span>&#160;<span class="comment"> * in the documentation and/or other materials provided with the</span></div>
  104. <div class="line"><a name="l00015"></a><span class="lineno"> 15</span>&#160;<span class="comment"> * distribution.</span></div>
  105. <div class="line"><a name="l00016"></a><span class="lineno"> 16</span>&#160;<span class="comment"> * * Neither the name of Google Inc. nor the names of its</span></div>
  106. <div class="line"><a name="l00017"></a><span class="lineno"> 17</span>&#160;<span class="comment"> * contributors may be used to endorse or promote products derived from</span></div>
  107. <div class="line"><a name="l00018"></a><span class="lineno"> 18</span>&#160;<span class="comment"> * this software without specific prior written permission.</span></div>
  108. <div class="line"><a name="l00019"></a><span class="lineno"> 19</span>&#160;<span class="comment"> *</span></div>
  109. <div class="line"><a name="l00020"></a><span class="lineno"> 20</span>&#160;<span class="comment"> * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS</span></div>
  110. <div class="line"><a name="l00021"></a><span class="lineno"> 21</span>&#160;<span class="comment"> * &quot;AS IS&quot; AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT</span></div>
  111. <div class="line"><a name="l00022"></a><span class="lineno"> 22</span>&#160;<span class="comment"> * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR</span></div>
  112. <div class="line"><a name="l00023"></a><span class="lineno"> 23</span>&#160;<span class="comment"> * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT</span></div>
  113. <div class="line"><a name="l00024"></a><span class="lineno"> 24</span>&#160;<span class="comment"> * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,</span></div>
  114. <div class="line"><a name="l00025"></a><span class="lineno"> 25</span>&#160;<span class="comment"> * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT</span></div>
  115. <div class="line"><a name="l00026"></a><span class="lineno"> 26</span>&#160;<span class="comment"> * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,</span></div>
  116. <div class="line"><a name="l00027"></a><span class="lineno"> 27</span>&#160;<span class="comment"> * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY</span></div>
  117. <div class="line"><a name="l00028"></a><span class="lineno"> 28</span>&#160;<span class="comment"> * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT</span></div>
  118. <div class="line"><a name="l00029"></a><span class="lineno"> 29</span>&#160;<span class="comment"> * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE</span></div>
  119. <div class="line"><a name="l00030"></a><span class="lineno"> 30</span>&#160;<span class="comment"> * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.</span></div>
  120. <div class="line"><a name="l00031"></a><span class="lineno"> 31</span>&#160;<span class="comment"> *</span></div>
  121. <div class="line"><a name="l00032"></a><span class="lineno"> 32</span>&#160;<span class="comment"> */</span></div>
  122. <div class="line"><a name="l00033"></a><span class="lineno"> 33</span>&#160;</div>
  123. <div class="line"><a name="l00034"></a><span class="lineno"> 34</span>&#160;<span class="preprocessor">#ifndef GRPCXX_IMPL_CODEGEN_ASYNC_STREAM_H</span></div>
  124. <div class="line"><a name="l00035"></a><span class="lineno"> 35</span>&#160;<span class="preprocessor"></span><span class="preprocessor">#define GRPCXX_IMPL_CODEGEN_ASYNC_STREAM_H</span></div>
  125. <div class="line"><a name="l00036"></a><span class="lineno"> 36</span>&#160;<span class="preprocessor"></span></div>
  126. <div class="line"><a name="l00037"></a><span class="lineno"> 37</span>&#160;<span class="preprocessor">#include &lt;<a class="code" href="channel__interface_8h.html">grpc++/impl/codegen/channel_interface.h</a>&gt;</span></div>
  127. <div class="line"><a name="l00038"></a><span class="lineno"> 38</span>&#160;<span class="preprocessor">#include &lt;<a class="code" href="codegen_2call_8h.html">grpc++/impl/codegen/call.h</a>&gt;</span></div>
  128. <div class="line"><a name="l00039"></a><span class="lineno"> 39</span>&#160;<span class="preprocessor">#include &lt;<a class="code" href="codegen_2service__type_8h.html">grpc++/impl/codegen/service_type.h</a>&gt;</span></div>
  129. <div class="line"><a name="l00040"></a><span class="lineno"> 40</span>&#160;<span class="preprocessor">#include &lt;<a class="code" href="impl_2codegen_2server__context_8h.html">grpc++/impl/codegen/server_context.h</a>&gt;</span></div>
  130. <div class="line"><a name="l00041"></a><span class="lineno"> 41</span>&#160;<span class="preprocessor">#include &lt;<a class="code" href="impl_2codegen_2status_8h.html">grpc++/impl/codegen/status.h</a>&gt;</span></div>
  131. <div class="line"><a name="l00042"></a><span class="lineno"> 42</span>&#160;</div>
  132. <div class="line"><a name="l00043"></a><span class="lineno"> 43</span>&#160;<span class="keyword">namespace </span>grpc {</div>
  133. <div class="line"><a name="l00044"></a><span class="lineno"> 44</span>&#160;</div>
  134. <div class="line"><a name="l00045"></a><span class="lineno"> 45</span>&#160;<span class="keyword">class </span>CompletionQueue;</div>
  135. <div class="line"><a name="l00046"></a><span class="lineno"> 46</span>&#160;</div>
  136. <div class="line"><a name="l00048"></a><span class="lineno"><a class="line" href="classgrpc_1_1_client_async_streaming_interface.html"> 48</a></span>&#160;<span class="keyword">class </span><a class="code" href="classgrpc_1_1_client_async_streaming_interface.html">ClientAsyncStreamingInterface</a> {</div>
  137. <div class="line"><a name="l00049"></a><span class="lineno"> 49</span>&#160; <span class="keyword">public</span>:</div>
  138. <div class="line"><a name="l00050"></a><span class="lineno"><a class="line" href="classgrpc_1_1_client_async_streaming_interface.html#a103c33e82dbf1715749886c4249f3f28"> 50</a></span>&#160; <span class="keyword">virtual</span> <a class="code" href="classgrpc_1_1_client_async_streaming_interface.html#a103c33e82dbf1715749886c4249f3f28">~ClientAsyncStreamingInterface</a>() {}</div>
  139. <div class="line"><a name="l00051"></a><span class="lineno"> 51</span>&#160;</div>
  140. <div class="line"><a name="l00056"></a><span class="lineno"> 56</span>&#160; <span class="keyword">virtual</span> <span class="keywordtype">void</span> <a class="code" href="classgrpc_1_1_client_async_streaming_interface.html#ad83bfe2febf4a6296b7d2646799b8174">ReadInitialMetadata</a>(<span class="keywordtype">void</span>* tag) = 0;</div>
  141. <div class="line"><a name="l00057"></a><span class="lineno"> 57</span>&#160;</div>
  142. <div class="line"><a name="l00062"></a><span class="lineno"> 62</span>&#160; <span class="keyword">virtual</span> <span class="keywordtype">void</span> <a class="code" href="classgrpc_1_1_client_async_streaming_interface.html#afc1cfbd1514fea47088bc837bb578a24">Finish</a>(<a class="code" href="classgrpc_1_1_status.html">Status</a>* status, <span class="keywordtype">void</span>* tag) = 0;</div>
  143. <div class="line"><a name="l00063"></a><span class="lineno"> 63</span>&#160;};</div>
  144. <div class="line"><a name="l00064"></a><span class="lineno"> 64</span>&#160;</div>
  145. <div class="line"><a name="l00066"></a><span class="lineno"> 66</span>&#160;<span class="keyword">template</span> &lt;<span class="keyword">class</span> R&gt;</div>
  146. <div class="line"><a name="l00067"></a><span class="lineno"><a class="line" href="classgrpc_1_1_async_reader_interface.html"> 67</a></span>&#160;<span class="keyword">class </span><a class="code" href="classgrpc_1_1_async_reader_interface.html">AsyncReaderInterface</a> {</div>
  147. <div class="line"><a name="l00068"></a><span class="lineno"> 68</span>&#160; <span class="keyword">public</span>:</div>
  148. <div class="line"><a name="l00069"></a><span class="lineno"><a class="line" href="classgrpc_1_1_async_reader_interface.html#ac7845d2df90fb380008aadb7f5f2f379"> 69</a></span>&#160; <span class="keyword">virtual</span> <a class="code" href="classgrpc_1_1_async_reader_interface.html#ac7845d2df90fb380008aadb7f5f2f379">~AsyncReaderInterface</a>() {}</div>
  149. <div class="line"><a name="l00070"></a><span class="lineno"> 70</span>&#160;</div>
  150. <div class="line"><a name="l00076"></a><span class="lineno"> 76</span>&#160; <span class="keyword">virtual</span> <span class="keywordtype">void</span> <a class="code" href="classgrpc_1_1_async_reader_interface.html#aa644cf63c12ae8c9d5fda16a361f8a11">Read</a>(R* msg, <span class="keywordtype">void</span>* tag) = 0;</div>
  151. <div class="line"><a name="l00077"></a><span class="lineno"> 77</span>&#160;};</div>
  152. <div class="line"><a name="l00078"></a><span class="lineno"> 78</span>&#160;</div>
  153. <div class="line"><a name="l00080"></a><span class="lineno"> 80</span>&#160;<span class="keyword">template</span> &lt;<span class="keyword">class</span> W&gt;</div>
  154. <div class="line"><a name="l00081"></a><span class="lineno"><a class="line" href="classgrpc_1_1_async_writer_interface.html"> 81</a></span>&#160;<span class="keyword">class </span><a class="code" href="classgrpc_1_1_async_writer_interface.html">AsyncWriterInterface</a> {</div>
  155. <div class="line"><a name="l00082"></a><span class="lineno"> 82</span>&#160; <span class="keyword">public</span>:</div>
  156. <div class="line"><a name="l00083"></a><span class="lineno"><a class="line" href="classgrpc_1_1_async_writer_interface.html#a94cc9e4ed13c8fe4a1d883d465477ddd"> 83</a></span>&#160; <span class="keyword">virtual</span> <a class="code" href="classgrpc_1_1_async_writer_interface.html#a94cc9e4ed13c8fe4a1d883d465477ddd">~AsyncWriterInterface</a>() {}</div>
  157. <div class="line"><a name="l00084"></a><span class="lineno"> 84</span>&#160;</div>
  158. <div class="line"><a name="l00093"></a><span class="lineno"> 93</span>&#160; <span class="keyword">virtual</span> <span class="keywordtype">void</span> <a class="code" href="classgrpc_1_1_async_writer_interface.html#a40c1091ac5cb5243c874da725ae291b4">Write</a>(<span class="keyword">const</span> W&amp; msg, <span class="keywordtype">void</span>* tag) = 0;</div>
  159. <div class="line"><a name="l00094"></a><span class="lineno"> 94</span>&#160;};</div>
  160. <div class="line"><a name="l00095"></a><span class="lineno"> 95</span>&#160;</div>
  161. <div class="line"><a name="l00096"></a><span class="lineno"> 96</span>&#160;<span class="keyword">template</span> &lt;<span class="keyword">class</span> R&gt;</div>
  162. <div class="line"><a name="l00097"></a><span class="lineno"><a class="line" href="classgrpc_1_1_client_async_reader_interface.html"> 97</a></span>&#160;<span class="keyword">class </span><a class="code" href="classgrpc_1_1_client_async_reader_interface.html">ClientAsyncReaderInterface</a> : <span class="keyword">public</span> <a class="code" href="classgrpc_1_1_client_async_streaming_interface.html">ClientAsyncStreamingInterface</a>,</div>
  163. <div class="line"><a name="l00098"></a><span class="lineno"> 98</span>&#160; <span class="keyword">public</span> <a class="code" href="classgrpc_1_1_async_reader_interface.html">AsyncReaderInterface</a>&lt;R&gt; {};</div>
  164. <div class="line"><a name="l00099"></a><span class="lineno"> 99</span>&#160;</div>
  165. <div class="line"><a name="l00100"></a><span class="lineno"> 100</span>&#160;<span class="keyword">template</span> &lt;<span class="keyword">class</span> R&gt;</div>
  166. <div class="line"><a name="l00101"></a><span class="lineno"><a class="line" href="classgrpc_1_1_client_async_reader.html"> 101</a></span>&#160;<span class="keyword">class </span><a class="code" href="classgrpc_1_1_client_async_reader.html">ClientAsyncReader</a> <a class="code" href="impl_2codegen_2config_8h.html#ab2216aa6e0ffe505e1ec362a9621a7f9">GRPC_FINAL</a> : <span class="keyword">public</span> <a class="code" href="classgrpc_1_1_client_async_reader_interface.html">ClientAsyncReaderInterface</a>&lt;R&gt; {</div>
  167. <div class="line"><a name="l00102"></a><span class="lineno"> 102</span>&#160; <span class="keyword">public</span>:</div>
  168. <div class="line"><a name="l00104"></a><span class="lineno"> 104</span>&#160; <span class="keyword">template</span> &lt;<span class="keyword">class</span> W&gt;</div>
  169. <div class="line"><a name="l00105"></a><span class="lineno"><a class="line" href="classgrpc_1_1_client_async_reader.html#aa14e3bc04d9852009f8b3094ce0d3ed4"> 105</a></span>&#160; <a class="code" href="classgrpc_1_1_client_async_reader.html#aa14e3bc04d9852009f8b3094ce0d3ed4">ClientAsyncReader</a>(<a class="code" href="classgrpc_1_1_channel_interface.html">ChannelInterface</a>* channel, <a class="code" href="classgrpc_1_1_completion_queue.html">CompletionQueue</a>* cq,</div>
  170. <div class="line"><a name="l00106"></a><span class="lineno"> 106</span>&#160; <span class="keyword">const</span> <a class="code" href="classgrpc_1_1_rpc_method.html">RpcMethod</a>&amp; method, <a class="code" href="classgrpc_1_1_client_context.html">ClientContext</a>* context,</div>
  171. <div class="line"><a name="l00107"></a><span class="lineno"> 107</span>&#160; <span class="keyword">const</span> W&amp; request, <span class="keywordtype">void</span>* tag)</div>
  172. <div class="line"><a name="l00108"></a><span class="lineno"> 108</span>&#160; : context_(context), call_(channel-&gt;CreateCall(method, context, cq)) {</div>
  173. <div class="line"><a name="l00109"></a><span class="lineno"> 109</span>&#160; init_ops_.set_output_tag(tag);</div>
  174. <div class="line"><a name="l00110"></a><span class="lineno"> 110</span>&#160; init_ops_.SendInitialMetadata(context-&gt;send_initial_metadata_);</div>
  175. <div class="line"><a name="l00111"></a><span class="lineno"> 111</span>&#160; <span class="comment">// TODO(ctiller): don&#39;t assert</span></div>
  176. <div class="line"><a name="l00112"></a><span class="lineno"> 112</span>&#160; GPR_ASSERT(init_ops_.SendMessage(request).ok());</div>
  177. <div class="line"><a name="l00113"></a><span class="lineno"> 113</span>&#160; init_ops_.ClientSendClose();</div>
  178. <div class="line"><a name="l00114"></a><span class="lineno"> 114</span>&#160; call_.<a class="code" href="classgrpc_1_1_call.html#a78ca141a1008fbbb122ee4de076edcc4">PerformOps</a>(&amp;init_ops_);</div>
  179. <div class="line"><a name="l00115"></a><span class="lineno"> 115</span>&#160; }</div>
  180. <div class="line"><a name="l00116"></a><span class="lineno"> 116</span>&#160;</div>
  181. <div class="line"><a name="l00117"></a><span class="lineno"><a class="line" href="classgrpc_1_1_client_async_reader.html#a0e5b71e2620dc95fe41305eef7ee7863"> 117</a></span>&#160; <span class="keywordtype">void</span> <a class="code" href="classgrpc_1_1_client_async_reader.html#a0e5b71e2620dc95fe41305eef7ee7863">ReadInitialMetadata</a>(<span class="keywordtype">void</span>* tag) <a class="code" href="impl_2codegen_2config_8h.html#a9a884d706be26697c9c892365a3402a9">GRPC_OVERRIDE</a> {</div>
  182. <div class="line"><a name="l00118"></a><span class="lineno"> 118</span>&#160; GPR_ASSERT(!context_-&gt;initial_metadata_received_);</div>
  183. <div class="line"><a name="l00119"></a><span class="lineno"> 119</span>&#160;</div>
  184. <div class="line"><a name="l00120"></a><span class="lineno"> 120</span>&#160; meta_ops_.set_output_tag(tag);</div>
  185. <div class="line"><a name="l00121"></a><span class="lineno"> 121</span>&#160; meta_ops_.RecvInitialMetadata(context_);</div>
  186. <div class="line"><a name="l00122"></a><span class="lineno"> 122</span>&#160; call_.<a class="code" href="classgrpc_1_1_call.html#a78ca141a1008fbbb122ee4de076edcc4">PerformOps</a>(&amp;meta_ops_);</div>
  187. <div class="line"><a name="l00123"></a><span class="lineno"> 123</span>&#160; }</div>
  188. <div class="line"><a name="l00124"></a><span class="lineno"> 124</span>&#160;</div>
  189. <div class="line"><a name="l00125"></a><span class="lineno"><a class="line" href="classgrpc_1_1_client_async_reader.html#aaf9f76ba76be0a0144bbdf44d740731d"> 125</a></span>&#160; <span class="keywordtype">void</span> <a class="code" href="classgrpc_1_1_client_async_reader.html#aaf9f76ba76be0a0144bbdf44d740731d">Read</a>(R* msg, <span class="keywordtype">void</span>* tag) <a class="code" href="impl_2codegen_2config_8h.html#a9a884d706be26697c9c892365a3402a9">GRPC_OVERRIDE</a> {</div>
  190. <div class="line"><a name="l00126"></a><span class="lineno"> 126</span>&#160; read_ops_.set_output_tag(tag);</div>
  191. <div class="line"><a name="l00127"></a><span class="lineno"> 127</span>&#160; <span class="keywordflow">if</span> (!context_-&gt;initial_metadata_received_) {</div>
  192. <div class="line"><a name="l00128"></a><span class="lineno"> 128</span>&#160; read_ops_.RecvInitialMetadata(context_);</div>
  193. <div class="line"><a name="l00129"></a><span class="lineno"> 129</span>&#160; }</div>
  194. <div class="line"><a name="l00130"></a><span class="lineno"> 130</span>&#160; read_ops_.RecvMessage(msg);</div>
  195. <div class="line"><a name="l00131"></a><span class="lineno"> 131</span>&#160; call_.<a class="code" href="classgrpc_1_1_call.html#a78ca141a1008fbbb122ee4de076edcc4">PerformOps</a>(&amp;read_ops_);</div>
  196. <div class="line"><a name="l00132"></a><span class="lineno"> 132</span>&#160; }</div>
  197. <div class="line"><a name="l00133"></a><span class="lineno"> 133</span>&#160;</div>
  198. <div class="line"><a name="l00134"></a><span class="lineno"><a class="line" href="classgrpc_1_1_client_async_reader.html#a91bfabf65e2dc955b6983bc0ece5a73f"> 134</a></span>&#160; <span class="keywordtype">void</span> <a class="code" href="classgrpc_1_1_client_async_reader.html#a91bfabf65e2dc955b6983bc0ece5a73f">Finish</a>(<a class="code" href="classgrpc_1_1_status.html">Status</a>* status, <span class="keywordtype">void</span>* tag) <a class="code" href="impl_2codegen_2config_8h.html#a9a884d706be26697c9c892365a3402a9">GRPC_OVERRIDE</a> {</div>
  199. <div class="line"><a name="l00135"></a><span class="lineno"> 135</span>&#160; finish_ops_.set_output_tag(tag);</div>
  200. <div class="line"><a name="l00136"></a><span class="lineno"> 136</span>&#160; <span class="keywordflow">if</span> (!context_-&gt;initial_metadata_received_) {</div>
  201. <div class="line"><a name="l00137"></a><span class="lineno"> 137</span>&#160; finish_ops_.RecvInitialMetadata(context_);</div>
  202. <div class="line"><a name="l00138"></a><span class="lineno"> 138</span>&#160; }</div>
  203. <div class="line"><a name="l00139"></a><span class="lineno"> 139</span>&#160; finish_ops_.ClientRecvStatus(context_, status);</div>
  204. <div class="line"><a name="l00140"></a><span class="lineno"> 140</span>&#160; call_.<a class="code" href="classgrpc_1_1_call.html#a78ca141a1008fbbb122ee4de076edcc4">PerformOps</a>(&amp;finish_ops_);</div>
  205. <div class="line"><a name="l00141"></a><span class="lineno"> 141</span>&#160; }</div>
  206. <div class="line"><a name="l00142"></a><span class="lineno"> 142</span>&#160;</div>
  207. <div class="line"><a name="l00143"></a><span class="lineno"> 143</span>&#160; <span class="keyword">private</span>:</div>
  208. <div class="line"><a name="l00144"></a><span class="lineno"> 144</span>&#160; <a class="code" href="classgrpc_1_1_client_context.html">ClientContext</a>* context_;</div>
  209. <div class="line"><a name="l00145"></a><span class="lineno"> 145</span>&#160; <a class="code" href="classgrpc_1_1_call.html">Call</a> call_;</div>
  210. <div class="line"><a name="l00146"></a><span class="lineno"> 146</span>&#160; <a class="code" href="classgrpc_1_1_call_op_set.html">CallOpSet&lt;CallOpSendInitialMetadata, CallOpSendMessage, CallOpClientSendClose&gt;</a></div>
  211. <div class="line"><a name="l00147"></a><span class="lineno"> 147</span>&#160; init_ops_;</div>
  212. <div class="line"><a name="l00148"></a><span class="lineno"> 148</span>&#160; <a class="code" href="classgrpc_1_1_call_op_set.html">CallOpSet&lt;CallOpRecvInitialMetadata&gt;</a> meta_ops_;</div>
  213. <div class="line"><a name="l00149"></a><span class="lineno"> 149</span>&#160; <a class="code" href="classgrpc_1_1_call_op_set.html">CallOpSet&lt;CallOpRecvInitialMetadata, CallOpRecvMessage&lt;R&gt;</a>&gt; read_ops_;</div>
  214. <div class="line"><a name="l00150"></a><span class="lineno"> 150</span>&#160; <a class="code" href="classgrpc_1_1_call_op_set.html">CallOpSet&lt;CallOpRecvInitialMetadata, CallOpClientRecvStatus&gt;</a> finish_ops_;</div>
  215. <div class="line"><a name="l00151"></a><span class="lineno"> 151</span>&#160;};</div>
  216. <div class="line"><a name="l00152"></a><span class="lineno"> 152</span>&#160;</div>
  217. <div class="line"><a name="l00154"></a><span class="lineno"> 154</span>&#160;<span class="keyword">template</span> &lt;<span class="keyword">class</span> W&gt;</div>
  218. <div class="line"><a name="l00155"></a><span class="lineno"><a class="line" href="classgrpc_1_1_client_async_writer_interface.html"> 155</a></span>&#160;<span class="keyword">class </span><a class="code" href="classgrpc_1_1_client_async_writer_interface.html">ClientAsyncWriterInterface</a> : <span class="keyword">public</span> <a class="code" href="classgrpc_1_1_client_async_streaming_interface.html">ClientAsyncStreamingInterface</a>,</div>
  219. <div class="line"><a name="l00156"></a><span class="lineno"> 156</span>&#160; <span class="keyword">public</span> <a class="code" href="classgrpc_1_1_async_writer_interface.html">AsyncWriterInterface</a>&lt;W&gt; {</div>
  220. <div class="line"><a name="l00157"></a><span class="lineno"> 157</span>&#160; <span class="keyword">public</span>:</div>
  221. <div class="line"><a name="l00161"></a><span class="lineno"> 161</span>&#160; <span class="keyword">virtual</span> <span class="keywordtype">void</span> <a class="code" href="classgrpc_1_1_client_async_writer_interface.html#a488d42d85f8e34902401e013572ff822">WritesDone</a>(<span class="keywordtype">void</span>* tag) = 0;</div>
  222. <div class="line"><a name="l00162"></a><span class="lineno"> 162</span>&#160;};</div>
  223. <div class="line"><a name="l00163"></a><span class="lineno"> 163</span>&#160;</div>
  224. <div class="line"><a name="l00164"></a><span class="lineno"> 164</span>&#160;<span class="keyword">template</span> &lt;<span class="keyword">class</span> W&gt;</div>
  225. <div class="line"><a name="l00165"></a><span class="lineno"><a class="line" href="classgrpc_1_1_client_async_writer.html"> 165</a></span>&#160;<span class="keyword">class </span><a class="code" href="classgrpc_1_1_client_async_writer.html">ClientAsyncWriter</a> <a class="code" href="impl_2codegen_2config_8h.html#ab2216aa6e0ffe505e1ec362a9621a7f9">GRPC_FINAL</a> : <span class="keyword">public</span> <a class="code" href="classgrpc_1_1_client_async_writer_interface.html">ClientAsyncWriterInterface</a>&lt;W&gt; {</div>
  226. <div class="line"><a name="l00166"></a><span class="lineno"> 166</span>&#160; <span class="keyword">public</span>:</div>
  227. <div class="line"><a name="l00167"></a><span class="lineno"> 167</span>&#160; <span class="keyword">template</span> &lt;<span class="keyword">class</span> R&gt;</div>
  228. <div class="line"><a name="l00168"></a><span class="lineno"><a class="line" href="classgrpc_1_1_client_async_writer.html#ad4903b1736b423c076bac8e23db345f6"> 168</a></span>&#160; <a class="code" href="classgrpc_1_1_client_async_writer.html#ad4903b1736b423c076bac8e23db345f6">ClientAsyncWriter</a>(<a class="code" href="classgrpc_1_1_channel_interface.html">ChannelInterface</a>* channel, <a class="code" href="classgrpc_1_1_completion_queue.html">CompletionQueue</a>* cq,</div>
  229. <div class="line"><a name="l00169"></a><span class="lineno"> 169</span>&#160; <span class="keyword">const</span> <a class="code" href="classgrpc_1_1_rpc_method.html">RpcMethod</a>&amp; method, <a class="code" href="classgrpc_1_1_client_context.html">ClientContext</a>* context,</div>
  230. <div class="line"><a name="l00170"></a><span class="lineno"> 170</span>&#160; R* response, <span class="keywordtype">void</span>* tag)</div>
  231. <div class="line"><a name="l00171"></a><span class="lineno"> 171</span>&#160; : context_(context), call_(channel-&gt;CreateCall(method, context, cq)) {</div>
  232. <div class="line"><a name="l00172"></a><span class="lineno"> 172</span>&#160; finish_ops_.RecvMessage(response);</div>
  233. <div class="line"><a name="l00173"></a><span class="lineno"> 173</span>&#160;</div>
  234. <div class="line"><a name="l00174"></a><span class="lineno"> 174</span>&#160; init_ops_.set_output_tag(tag);</div>
  235. <div class="line"><a name="l00175"></a><span class="lineno"> 175</span>&#160; init_ops_.SendInitialMetadata(context-&gt;send_initial_metadata_);</div>
  236. <div class="line"><a name="l00176"></a><span class="lineno"> 176</span>&#160; call_.<a class="code" href="classgrpc_1_1_call.html#a78ca141a1008fbbb122ee4de076edcc4">PerformOps</a>(&amp;init_ops_);</div>
  237. <div class="line"><a name="l00177"></a><span class="lineno"> 177</span>&#160; }</div>
  238. <div class="line"><a name="l00178"></a><span class="lineno"> 178</span>&#160;</div>
  239. <div class="line"><a name="l00179"></a><span class="lineno"><a class="line" href="classgrpc_1_1_client_async_writer.html#a1db45c4f5817db4f770c08dab64916c7"> 179</a></span>&#160; <span class="keywordtype">void</span> <a class="code" href="classgrpc_1_1_client_async_writer.html#a1db45c4f5817db4f770c08dab64916c7">ReadInitialMetadata</a>(<span class="keywordtype">void</span>* tag) <a class="code" href="impl_2codegen_2config_8h.html#a9a884d706be26697c9c892365a3402a9">GRPC_OVERRIDE</a> {</div>
  240. <div class="line"><a name="l00180"></a><span class="lineno"> 180</span>&#160; GPR_ASSERT(!context_-&gt;initial_metadata_received_);</div>
  241. <div class="line"><a name="l00181"></a><span class="lineno"> 181</span>&#160;</div>
  242. <div class="line"><a name="l00182"></a><span class="lineno"> 182</span>&#160; meta_ops_.set_output_tag(tag);</div>
  243. <div class="line"><a name="l00183"></a><span class="lineno"> 183</span>&#160; meta_ops_.RecvInitialMetadata(context_);</div>
  244. <div class="line"><a name="l00184"></a><span class="lineno"> 184</span>&#160; call_.<a class="code" href="classgrpc_1_1_call.html#a78ca141a1008fbbb122ee4de076edcc4">PerformOps</a>(&amp;meta_ops_);</div>
  245. <div class="line"><a name="l00185"></a><span class="lineno"> 185</span>&#160; }</div>
  246. <div class="line"><a name="l00186"></a><span class="lineno"> 186</span>&#160;</div>
  247. <div class="line"><a name="l00187"></a><span class="lineno"><a class="line" href="classgrpc_1_1_client_async_writer.html#a544f9e4c310b251bf3c7b84fd035d20a"> 187</a></span>&#160; <span class="keywordtype">void</span> <a class="code" href="classgrpc_1_1_client_async_writer.html#a544f9e4c310b251bf3c7b84fd035d20a">Write</a>(<span class="keyword">const</span> W&amp; msg, <span class="keywordtype">void</span>* tag) <a class="code" href="impl_2codegen_2config_8h.html#a9a884d706be26697c9c892365a3402a9">GRPC_OVERRIDE</a> {</div>
  248. <div class="line"><a name="l00188"></a><span class="lineno"> 188</span>&#160; write_ops_.set_output_tag(tag);</div>
  249. <div class="line"><a name="l00189"></a><span class="lineno"> 189</span>&#160; <span class="comment">// TODO(ctiller): don&#39;t assert</span></div>
  250. <div class="line"><a name="l00190"></a><span class="lineno"> 190</span>&#160; GPR_ASSERT(write_ops_.SendMessage(msg).ok());</div>
  251. <div class="line"><a name="l00191"></a><span class="lineno"> 191</span>&#160; call_.<a class="code" href="classgrpc_1_1_call.html#a78ca141a1008fbbb122ee4de076edcc4">PerformOps</a>(&amp;write_ops_);</div>
  252. <div class="line"><a name="l00192"></a><span class="lineno"> 192</span>&#160; }</div>
  253. <div class="line"><a name="l00193"></a><span class="lineno"> 193</span>&#160;</div>
  254. <div class="line"><a name="l00194"></a><span class="lineno"><a class="line" href="classgrpc_1_1_client_async_writer.html#af9fbf77049c3e5402913c0edeccf3d47"> 194</a></span>&#160; <span class="keywordtype">void</span> <a class="code" href="classgrpc_1_1_client_async_writer.html#af9fbf77049c3e5402913c0edeccf3d47">WritesDone</a>(<span class="keywordtype">void</span>* tag) <a class="code" href="impl_2codegen_2config_8h.html#a9a884d706be26697c9c892365a3402a9">GRPC_OVERRIDE</a> {</div>
  255. <div class="line"><a name="l00195"></a><span class="lineno"> 195</span>&#160; writes_done_ops_.set_output_tag(tag);</div>
  256. <div class="line"><a name="l00196"></a><span class="lineno"> 196</span>&#160; writes_done_ops_.ClientSendClose();</div>
  257. <div class="line"><a name="l00197"></a><span class="lineno"> 197</span>&#160; call_.<a class="code" href="classgrpc_1_1_call.html#a78ca141a1008fbbb122ee4de076edcc4">PerformOps</a>(&amp;writes_done_ops_);</div>
  258. <div class="line"><a name="l00198"></a><span class="lineno"> 198</span>&#160; }</div>
  259. <div class="line"><a name="l00199"></a><span class="lineno"> 199</span>&#160;</div>
  260. <div class="line"><a name="l00200"></a><span class="lineno"><a class="line" href="classgrpc_1_1_client_async_writer.html#ad37af0a7fc27fc90e168fdb90eb52d8b"> 200</a></span>&#160; <span class="keywordtype">void</span> <a class="code" href="classgrpc_1_1_client_async_writer.html#ad37af0a7fc27fc90e168fdb90eb52d8b">Finish</a>(<a class="code" href="classgrpc_1_1_status.html">Status</a>* status, <span class="keywordtype">void</span>* tag) <a class="code" href="impl_2codegen_2config_8h.html#a9a884d706be26697c9c892365a3402a9">GRPC_OVERRIDE</a> {</div>
  261. <div class="line"><a name="l00201"></a><span class="lineno"> 201</span>&#160; finish_ops_.set_output_tag(tag);</div>
  262. <div class="line"><a name="l00202"></a><span class="lineno"> 202</span>&#160; <span class="keywordflow">if</span> (!context_-&gt;initial_metadata_received_) {</div>
  263. <div class="line"><a name="l00203"></a><span class="lineno"> 203</span>&#160; finish_ops_.RecvInitialMetadata(context_);</div>
  264. <div class="line"><a name="l00204"></a><span class="lineno"> 204</span>&#160; }</div>
  265. <div class="line"><a name="l00205"></a><span class="lineno"> 205</span>&#160; finish_ops_.ClientRecvStatus(context_, status);</div>
  266. <div class="line"><a name="l00206"></a><span class="lineno"> 206</span>&#160; call_.<a class="code" href="classgrpc_1_1_call.html#a78ca141a1008fbbb122ee4de076edcc4">PerformOps</a>(&amp;finish_ops_);</div>
  267. <div class="line"><a name="l00207"></a><span class="lineno"> 207</span>&#160; }</div>
  268. <div class="line"><a name="l00208"></a><span class="lineno"> 208</span>&#160;</div>
  269. <div class="line"><a name="l00209"></a><span class="lineno"> 209</span>&#160; <span class="keyword">private</span>:</div>
  270. <div class="line"><a name="l00210"></a><span class="lineno"> 210</span>&#160; <a class="code" href="classgrpc_1_1_client_context.html">ClientContext</a>* context_;</div>
  271. <div class="line"><a name="l00211"></a><span class="lineno"> 211</span>&#160; <a class="code" href="classgrpc_1_1_call.html">Call</a> call_;</div>
  272. <div class="line"><a name="l00212"></a><span class="lineno"> 212</span>&#160; <a class="code" href="classgrpc_1_1_call_op_set.html">CallOpSet&lt;CallOpSendInitialMetadata&gt;</a> init_ops_;</div>
  273. <div class="line"><a name="l00213"></a><span class="lineno"> 213</span>&#160; <a class="code" href="classgrpc_1_1_call_op_set.html">CallOpSet&lt;CallOpRecvInitialMetadata&gt;</a> meta_ops_;</div>
  274. <div class="line"><a name="l00214"></a><span class="lineno"> 214</span>&#160; <a class="code" href="classgrpc_1_1_call_op_set.html">CallOpSet&lt;CallOpSendMessage&gt;</a> write_ops_;</div>
  275. <div class="line"><a name="l00215"></a><span class="lineno"> 215</span>&#160; <a class="code" href="classgrpc_1_1_call_op_set.html">CallOpSet&lt;CallOpClientSendClose&gt;</a> writes_done_ops_;</div>
  276. <div class="line"><a name="l00216"></a><span class="lineno"> 216</span>&#160; <a class="code" href="classgrpc_1_1_call_op_set.html">CallOpSet</a>&lt;<a class="code" href="classgrpc_1_1_call_op_recv_initial_metadata.html">CallOpRecvInitialMetadata</a>, <a class="code" href="classgrpc_1_1_call_op_generic_recv_message.html">CallOpGenericRecvMessage</a>,</div>
  277. <div class="line"><a name="l00217"></a><span class="lineno"> 217</span>&#160; <a class="code" href="classgrpc_1_1_call_op_client_recv_status.html">CallOpClientRecvStatus</a>&gt; finish_ops_;</div>
  278. <div class="line"><a name="l00218"></a><span class="lineno"> 218</span>&#160;};</div>
  279. <div class="line"><a name="l00219"></a><span class="lineno"> 219</span>&#160;</div>
  280. <div class="line"><a name="l00221"></a><span class="lineno"> 221</span>&#160;<span class="keyword">template</span> &lt;<span class="keyword">class</span> W, <span class="keyword">class</span> R&gt;</div>
  281. <div class="line"><a name="l00222"></a><span class="lineno"><a class="line" href="classgrpc_1_1_client_async_reader_writer_interface.html"> 222</a></span>&#160;<span class="keyword">class </span><a class="code" href="classgrpc_1_1_client_async_reader_writer_interface.html">ClientAsyncReaderWriterInterface</a> : <span class="keyword">public</span> <a class="code" href="classgrpc_1_1_client_async_streaming_interface.html">ClientAsyncStreamingInterface</a>,</div>
  282. <div class="line"><a name="l00223"></a><span class="lineno"> 223</span>&#160; <span class="keyword">public</span> <a class="code" href="classgrpc_1_1_async_writer_interface.html">AsyncWriterInterface</a>&lt;W&gt;,</div>
  283. <div class="line"><a name="l00224"></a><span class="lineno"> 224</span>&#160; <span class="keyword">public</span> <a class="code" href="classgrpc_1_1_async_reader_interface.html">AsyncReaderInterface</a>&lt;R&gt; {</div>
  284. <div class="line"><a name="l00225"></a><span class="lineno"> 225</span>&#160; <span class="keyword">public</span>:</div>
  285. <div class="line"><a name="l00229"></a><span class="lineno"> 229</span>&#160; <span class="keyword">virtual</span> <span class="keywordtype">void</span> <a class="code" href="classgrpc_1_1_client_async_reader_writer_interface.html#a878193880df68ab969b697f1fcd7dbc3">WritesDone</a>(<span class="keywordtype">void</span>* tag) = 0;</div>
  286. <div class="line"><a name="l00230"></a><span class="lineno"> 230</span>&#160;};</div>
  287. <div class="line"><a name="l00231"></a><span class="lineno"> 231</span>&#160;</div>
  288. <div class="line"><a name="l00232"></a><span class="lineno"> 232</span>&#160;<span class="keyword">template</span> &lt;<span class="keyword">class</span> W, <span class="keyword">class</span> R&gt;</div>
  289. <div class="line"><a name="l00233"></a><span class="lineno"><a class="line" href="classgrpc_1_1_client_async_reader_writer.html"> 233</a></span>&#160;<span class="keyword">class </span><a class="code" href="classgrpc_1_1_client_async_reader_writer.html">ClientAsyncReaderWriter</a> <a class="code" href="impl_2codegen_2config_8h.html#ab2216aa6e0ffe505e1ec362a9621a7f9">GRPC_FINAL</a></div>
  290. <div class="line"><a name="l00234"></a><span class="lineno"> 234</span>&#160; : <span class="keyword">public</span> <a class="code" href="classgrpc_1_1_client_async_reader_writer_interface.html">ClientAsyncReaderWriterInterface</a>&lt;W, R&gt; {</div>
  291. <div class="line"><a name="l00235"></a><span class="lineno"> 235</span>&#160; <span class="keyword">public</span>:</div>
  292. <div class="line"><a name="l00236"></a><span class="lineno"><a class="line" href="classgrpc_1_1_client_async_reader_writer.html#a0511a6da96294a181471688be7765044"> 236</a></span>&#160; <a class="code" href="classgrpc_1_1_client_async_reader_writer.html#a0511a6da96294a181471688be7765044">ClientAsyncReaderWriter</a>(<a class="code" href="classgrpc_1_1_channel_interface.html">ChannelInterface</a>* channel, <a class="code" href="classgrpc_1_1_completion_queue.html">CompletionQueue</a>* cq,</div>
  293. <div class="line"><a name="l00237"></a><span class="lineno"> 237</span>&#160; <span class="keyword">const</span> <a class="code" href="classgrpc_1_1_rpc_method.html">RpcMethod</a>&amp; method, <a class="code" href="classgrpc_1_1_client_context.html">ClientContext</a>* context,</div>
  294. <div class="line"><a name="l00238"></a><span class="lineno"> 238</span>&#160; <span class="keywordtype">void</span>* tag)</div>
  295. <div class="line"><a name="l00239"></a><span class="lineno"> 239</span>&#160; : context_(context), call_(channel-&gt;CreateCall(method, context, cq)) {</div>
  296. <div class="line"><a name="l00240"></a><span class="lineno"> 240</span>&#160; init_ops_.set_output_tag(tag);</div>
  297. <div class="line"><a name="l00241"></a><span class="lineno"> 241</span>&#160; init_ops_.SendInitialMetadata(context-&gt;send_initial_metadata_);</div>
  298. <div class="line"><a name="l00242"></a><span class="lineno"> 242</span>&#160; call_.<a class="code" href="classgrpc_1_1_call.html#a78ca141a1008fbbb122ee4de076edcc4">PerformOps</a>(&amp;init_ops_);</div>
  299. <div class="line"><a name="l00243"></a><span class="lineno"> 243</span>&#160; }</div>
  300. <div class="line"><a name="l00244"></a><span class="lineno"> 244</span>&#160;</div>
  301. <div class="line"><a name="l00245"></a><span class="lineno"><a class="line" href="classgrpc_1_1_client_async_reader_writer.html#aebfcea780f028eb345887b6364f1e45a"> 245</a></span>&#160; <span class="keywordtype">void</span> <a class="code" href="classgrpc_1_1_client_async_reader_writer.html#aebfcea780f028eb345887b6364f1e45a">ReadInitialMetadata</a>(<span class="keywordtype">void</span>* tag) <a class="code" href="impl_2codegen_2config_8h.html#a9a884d706be26697c9c892365a3402a9">GRPC_OVERRIDE</a> {</div>
  302. <div class="line"><a name="l00246"></a><span class="lineno"> 246</span>&#160; GPR_ASSERT(!context_-&gt;initial_metadata_received_);</div>
  303. <div class="line"><a name="l00247"></a><span class="lineno"> 247</span>&#160;</div>
  304. <div class="line"><a name="l00248"></a><span class="lineno"> 248</span>&#160; meta_ops_.set_output_tag(tag);</div>
  305. <div class="line"><a name="l00249"></a><span class="lineno"> 249</span>&#160; meta_ops_.RecvInitialMetadata(context_);</div>
  306. <div class="line"><a name="l00250"></a><span class="lineno"> 250</span>&#160; call_.<a class="code" href="classgrpc_1_1_call.html#a78ca141a1008fbbb122ee4de076edcc4">PerformOps</a>(&amp;meta_ops_);</div>
  307. <div class="line"><a name="l00251"></a><span class="lineno"> 251</span>&#160; }</div>
  308. <div class="line"><a name="l00252"></a><span class="lineno"> 252</span>&#160;</div>
  309. <div class="line"><a name="l00253"></a><span class="lineno"><a class="line" href="classgrpc_1_1_client_async_reader_writer.html#a6f4dfc5fdd441b4997d5f1226eb32dbe"> 253</a></span>&#160; <span class="keywordtype">void</span> <a class="code" href="classgrpc_1_1_client_async_reader_writer.html#a6f4dfc5fdd441b4997d5f1226eb32dbe">Read</a>(R* msg, <span class="keywordtype">void</span>* tag) <a class="code" href="impl_2codegen_2config_8h.html#a9a884d706be26697c9c892365a3402a9">GRPC_OVERRIDE</a> {</div>
  310. <div class="line"><a name="l00254"></a><span class="lineno"> 254</span>&#160; read_ops_.set_output_tag(tag);</div>
  311. <div class="line"><a name="l00255"></a><span class="lineno"> 255</span>&#160; <span class="keywordflow">if</span> (!context_-&gt;initial_metadata_received_) {</div>
  312. <div class="line"><a name="l00256"></a><span class="lineno"> 256</span>&#160; read_ops_.RecvInitialMetadata(context_);</div>
  313. <div class="line"><a name="l00257"></a><span class="lineno"> 257</span>&#160; }</div>
  314. <div class="line"><a name="l00258"></a><span class="lineno"> 258</span>&#160; read_ops_.RecvMessage(msg);</div>
  315. <div class="line"><a name="l00259"></a><span class="lineno"> 259</span>&#160; call_.<a class="code" href="classgrpc_1_1_call.html#a78ca141a1008fbbb122ee4de076edcc4">PerformOps</a>(&amp;read_ops_);</div>
  316. <div class="line"><a name="l00260"></a><span class="lineno"> 260</span>&#160; }</div>
  317. <div class="line"><a name="l00261"></a><span class="lineno"> 261</span>&#160;</div>
  318. <div class="line"><a name="l00262"></a><span class="lineno"><a class="line" href="classgrpc_1_1_client_async_reader_writer.html#a585ad2f181b1b5041349243861f15994"> 262</a></span>&#160; <span class="keywordtype">void</span> <a class="code" href="classgrpc_1_1_client_async_reader_writer.html#a585ad2f181b1b5041349243861f15994">Write</a>(<span class="keyword">const</span> W&amp; msg, <span class="keywordtype">void</span>* tag) <a class="code" href="impl_2codegen_2config_8h.html#a9a884d706be26697c9c892365a3402a9">GRPC_OVERRIDE</a> {</div>
  319. <div class="line"><a name="l00263"></a><span class="lineno"> 263</span>&#160; write_ops_.set_output_tag(tag);</div>
  320. <div class="line"><a name="l00264"></a><span class="lineno"> 264</span>&#160; <span class="comment">// TODO(ctiller): don&#39;t assert</span></div>
  321. <div class="line"><a name="l00265"></a><span class="lineno"> 265</span>&#160; GPR_ASSERT(write_ops_.SendMessage(msg).ok());</div>
  322. <div class="line"><a name="l00266"></a><span class="lineno"> 266</span>&#160; call_.<a class="code" href="classgrpc_1_1_call.html#a78ca141a1008fbbb122ee4de076edcc4">PerformOps</a>(&amp;write_ops_);</div>
  323. <div class="line"><a name="l00267"></a><span class="lineno"> 267</span>&#160; }</div>
  324. <div class="line"><a name="l00268"></a><span class="lineno"> 268</span>&#160;</div>
  325. <div class="line"><a name="l00269"></a><span class="lineno"><a class="line" href="classgrpc_1_1_client_async_reader_writer.html#af45cfa2b9cb0a27b673c0c793540db4a"> 269</a></span>&#160; <span class="keywordtype">void</span> <a class="code" href="classgrpc_1_1_client_async_reader_writer.html#af45cfa2b9cb0a27b673c0c793540db4a">WritesDone</a>(<span class="keywordtype">void</span>* tag) <a class="code" href="impl_2codegen_2config_8h.html#a9a884d706be26697c9c892365a3402a9">GRPC_OVERRIDE</a> {</div>
  326. <div class="line"><a name="l00270"></a><span class="lineno"> 270</span>&#160; writes_done_ops_.set_output_tag(tag);</div>
  327. <div class="line"><a name="l00271"></a><span class="lineno"> 271</span>&#160; writes_done_ops_.ClientSendClose();</div>
  328. <div class="line"><a name="l00272"></a><span class="lineno"> 272</span>&#160; call_.<a class="code" href="classgrpc_1_1_call.html#a78ca141a1008fbbb122ee4de076edcc4">PerformOps</a>(&amp;writes_done_ops_);</div>
  329. <div class="line"><a name="l00273"></a><span class="lineno"> 273</span>&#160; }</div>
  330. <div class="line"><a name="l00274"></a><span class="lineno"> 274</span>&#160;</div>
  331. <div class="line"><a name="l00275"></a><span class="lineno"><a class="line" href="classgrpc_1_1_client_async_reader_writer.html#aa0b94fec5a1b7c22e4db8046b1f031cc"> 275</a></span>&#160; <span class="keywordtype">void</span> <a class="code" href="classgrpc_1_1_client_async_reader_writer.html#aa0b94fec5a1b7c22e4db8046b1f031cc">Finish</a>(<a class="code" href="classgrpc_1_1_status.html">Status</a>* status, <span class="keywordtype">void</span>* tag) <a class="code" href="impl_2codegen_2config_8h.html#a9a884d706be26697c9c892365a3402a9">GRPC_OVERRIDE</a> {</div>
  332. <div class="line"><a name="l00276"></a><span class="lineno"> 276</span>&#160; finish_ops_.set_output_tag(tag);</div>
  333. <div class="line"><a name="l00277"></a><span class="lineno"> 277</span>&#160; <span class="keywordflow">if</span> (!context_-&gt;initial_metadata_received_) {</div>
  334. <div class="line"><a name="l00278"></a><span class="lineno"> 278</span>&#160; finish_ops_.RecvInitialMetadata(context_);</div>
  335. <div class="line"><a name="l00279"></a><span class="lineno"> 279</span>&#160; }</div>
  336. <div class="line"><a name="l00280"></a><span class="lineno"> 280</span>&#160; finish_ops_.ClientRecvStatus(context_, status);</div>
  337. <div class="line"><a name="l00281"></a><span class="lineno"> 281</span>&#160; call_.<a class="code" href="classgrpc_1_1_call.html#a78ca141a1008fbbb122ee4de076edcc4">PerformOps</a>(&amp;finish_ops_);</div>
  338. <div class="line"><a name="l00282"></a><span class="lineno"> 282</span>&#160; }</div>
  339. <div class="line"><a name="l00283"></a><span class="lineno"> 283</span>&#160;</div>
  340. <div class="line"><a name="l00284"></a><span class="lineno"> 284</span>&#160; <span class="keyword">private</span>:</div>
  341. <div class="line"><a name="l00285"></a><span class="lineno"> 285</span>&#160; <a class="code" href="classgrpc_1_1_client_context.html">ClientContext</a>* context_;</div>
  342. <div class="line"><a name="l00286"></a><span class="lineno"> 286</span>&#160; <a class="code" href="classgrpc_1_1_call.html">Call</a> call_;</div>
  343. <div class="line"><a name="l00287"></a><span class="lineno"> 287</span>&#160; <a class="code" href="classgrpc_1_1_call_op_set.html">CallOpSet&lt;CallOpSendInitialMetadata&gt;</a> init_ops_;</div>
  344. <div class="line"><a name="l00288"></a><span class="lineno"> 288</span>&#160; <a class="code" href="classgrpc_1_1_call_op_set.html">CallOpSet&lt;CallOpRecvInitialMetadata&gt;</a> meta_ops_;</div>
  345. <div class="line"><a name="l00289"></a><span class="lineno"> 289</span>&#160; <a class="code" href="classgrpc_1_1_call_op_set.html">CallOpSet&lt;CallOpRecvInitialMetadata, CallOpRecvMessage&lt;R&gt;</a>&gt; read_ops_;</div>
  346. <div class="line"><a name="l00290"></a><span class="lineno"> 290</span>&#160; <a class="code" href="classgrpc_1_1_call_op_set.html">CallOpSet&lt;CallOpSendMessage&gt;</a> write_ops_;</div>
  347. <div class="line"><a name="l00291"></a><span class="lineno"> 291</span>&#160; <a class="code" href="classgrpc_1_1_call_op_set.html">CallOpSet&lt;CallOpClientSendClose&gt;</a> writes_done_ops_;</div>
  348. <div class="line"><a name="l00292"></a><span class="lineno"> 292</span>&#160; <a class="code" href="classgrpc_1_1_call_op_set.html">CallOpSet&lt;CallOpRecvInitialMetadata, CallOpClientRecvStatus&gt;</a> finish_ops_;</div>
  349. <div class="line"><a name="l00293"></a><span class="lineno"> 293</span>&#160;};</div>
  350. <div class="line"><a name="l00294"></a><span class="lineno"> 294</span>&#160;</div>
  351. <div class="line"><a name="l00295"></a><span class="lineno"> 295</span>&#160;<span class="keyword">template</span> &lt;<span class="keyword">class</span> W, <span class="keyword">class</span> R&gt;</div>
  352. <div class="line"><a name="l00296"></a><span class="lineno"><a class="line" href="classgrpc_1_1_server_async_reader.html"> 296</a></span>&#160;<span class="keyword">class </span><a class="code" href="classgrpc_1_1_server_async_reader.html">ServerAsyncReader</a> <a class="code" href="impl_2codegen_2config_8h.html#ab2216aa6e0ffe505e1ec362a9621a7f9">GRPC_FINAL</a> : <span class="keyword">public</span> <a class="code" href="classgrpc_1_1_server_async_streaming_interface.html">ServerAsyncStreamingInterface</a>,</div>
  353. <div class="line"><a name="l00297"></a><span class="lineno"> 297</span>&#160; <span class="keyword">public</span> <a class="code" href="classgrpc_1_1_async_reader_interface.html">AsyncReaderInterface</a>&lt;R&gt; {</div>
  354. <div class="line"><a name="l00298"></a><span class="lineno"> 298</span>&#160; <span class="keyword">public</span>:</div>
  355. <div class="line"><a name="l00299"></a><span class="lineno"><a class="line" href="classgrpc_1_1_server_async_reader.html#a7f351e1d526b250336402ee03b8cc75e"> 299</a></span>&#160; <span class="keyword">explicit</span> <a class="code" href="classgrpc_1_1_server_async_reader.html#a7f351e1d526b250336402ee03b8cc75e">ServerAsyncReader</a>(<a class="code" href="classgrpc_1_1_server_context.html">ServerContext</a>* ctx)</div>
  356. <div class="line"><a name="l00300"></a><span class="lineno"> 300</span>&#160; : call_(nullptr, nullptr, nullptr), ctx_(ctx) {}</div>
  357. <div class="line"><a name="l00301"></a><span class="lineno"> 301</span>&#160;</div>
  358. <div class="line"><a name="l00302"></a><span class="lineno"><a class="line" href="classgrpc_1_1_server_async_reader.html#a5d05028563e789203225c0ba548710b6"> 302</a></span>&#160; <span class="keywordtype">void</span> <a class="code" href="classgrpc_1_1_server_async_reader.html#a5d05028563e789203225c0ba548710b6">SendInitialMetadata</a>(<span class="keywordtype">void</span>* tag) <a class="code" href="impl_2codegen_2config_8h.html#a9a884d706be26697c9c892365a3402a9">GRPC_OVERRIDE</a> {</div>
  359. <div class="line"><a name="l00303"></a><span class="lineno"> 303</span>&#160; GPR_ASSERT(!ctx_-&gt;sent_initial_metadata_);</div>
  360. <div class="line"><a name="l00304"></a><span class="lineno"> 304</span>&#160;</div>
  361. <div class="line"><a name="l00305"></a><span class="lineno"> 305</span>&#160; meta_ops_.set_output_tag(tag);</div>
  362. <div class="line"><a name="l00306"></a><span class="lineno"> 306</span>&#160; meta_ops_.SendInitialMetadata(ctx_-&gt;initial_metadata_);</div>
  363. <div class="line"><a name="l00307"></a><span class="lineno"> 307</span>&#160; ctx_-&gt;sent_initial_metadata_ = <span class="keyword">true</span>;</div>
  364. <div class="line"><a name="l00308"></a><span class="lineno"> 308</span>&#160; call_.<a class="code" href="classgrpc_1_1_call.html#a78ca141a1008fbbb122ee4de076edcc4">PerformOps</a>(&amp;meta_ops_);</div>
  365. <div class="line"><a name="l00309"></a><span class="lineno"> 309</span>&#160; }</div>
  366. <div class="line"><a name="l00310"></a><span class="lineno"> 310</span>&#160;</div>
  367. <div class="line"><a name="l00311"></a><span class="lineno"><a class="line" href="classgrpc_1_1_server_async_reader.html#ac60c1f8d5373644f952377096f1a5b2f"> 311</a></span>&#160; <span class="keywordtype">void</span> <a class="code" href="classgrpc_1_1_server_async_reader.html#ac60c1f8d5373644f952377096f1a5b2f">Read</a>(R* msg, <span class="keywordtype">void</span>* tag) <a class="code" href="impl_2codegen_2config_8h.html#a9a884d706be26697c9c892365a3402a9">GRPC_OVERRIDE</a> {</div>
  368. <div class="line"><a name="l00312"></a><span class="lineno"> 312</span>&#160; read_ops_.set_output_tag(tag);</div>
  369. <div class="line"><a name="l00313"></a><span class="lineno"> 313</span>&#160; read_ops_.RecvMessage(msg);</div>
  370. <div class="line"><a name="l00314"></a><span class="lineno"> 314</span>&#160; call_.<a class="code" href="classgrpc_1_1_call.html#a78ca141a1008fbbb122ee4de076edcc4">PerformOps</a>(&amp;read_ops_);</div>
  371. <div class="line"><a name="l00315"></a><span class="lineno"> 315</span>&#160; }</div>
  372. <div class="line"><a name="l00316"></a><span class="lineno"> 316</span>&#160;</div>
  373. <div class="line"><a name="l00317"></a><span class="lineno"><a class="line" href="classgrpc_1_1_server_async_reader.html#aaa77b67709c07ab60bc190bce5ee9a59"> 317</a></span>&#160; <span class="keywordtype">void</span> <a class="code" href="classgrpc_1_1_server_async_reader.html#aaa77b67709c07ab60bc190bce5ee9a59">Finish</a>(<span class="keyword">const</span> W&amp; msg, <span class="keyword">const</span> <a class="code" href="classgrpc_1_1_status.html">Status</a>&amp; status, <span class="keywordtype">void</span>* tag) {</div>
  374. <div class="line"><a name="l00318"></a><span class="lineno"> 318</span>&#160; finish_ops_.set_output_tag(tag);</div>
  375. <div class="line"><a name="l00319"></a><span class="lineno"> 319</span>&#160; <span class="keywordflow">if</span> (!ctx_-&gt;sent_initial_metadata_) {</div>
  376. <div class="line"><a name="l00320"></a><span class="lineno"> 320</span>&#160; finish_ops_.SendInitialMetadata(ctx_-&gt;initial_metadata_);</div>
  377. <div class="line"><a name="l00321"></a><span class="lineno"> 321</span>&#160; ctx_-&gt;sent_initial_metadata_ = <span class="keyword">true</span>;</div>
  378. <div class="line"><a name="l00322"></a><span class="lineno"> 322</span>&#160; }</div>
  379. <div class="line"><a name="l00323"></a><span class="lineno"> 323</span>&#160; <span class="comment">// The response is dropped if the status is not OK.</span></div>
  380. <div class="line"><a name="l00324"></a><span class="lineno"> 324</span>&#160; <span class="keywordflow">if</span> (status.<a class="code" href="classgrpc_1_1_status.html#a1f5b65c54d4e6dd502897e36040714dc">ok</a>()) {</div>
  381. <div class="line"><a name="l00325"></a><span class="lineno"> 325</span>&#160; finish_ops_.ServerSendStatus(ctx_-&gt;trailing_metadata_,</div>
  382. <div class="line"><a name="l00326"></a><span class="lineno"> 326</span>&#160; finish_ops_.SendMessage(msg));</div>
  383. <div class="line"><a name="l00327"></a><span class="lineno"> 327</span>&#160; } <span class="keywordflow">else</span> {</div>
  384. <div class="line"><a name="l00328"></a><span class="lineno"> 328</span>&#160; finish_ops_.ServerSendStatus(ctx_-&gt;trailing_metadata_, status);</div>
  385. <div class="line"><a name="l00329"></a><span class="lineno"> 329</span>&#160; }</div>
  386. <div class="line"><a name="l00330"></a><span class="lineno"> 330</span>&#160; call_.<a class="code" href="classgrpc_1_1_call.html#a78ca141a1008fbbb122ee4de076edcc4">PerformOps</a>(&amp;finish_ops_);</div>
  387. <div class="line"><a name="l00331"></a><span class="lineno"> 331</span>&#160; }</div>
  388. <div class="line"><a name="l00332"></a><span class="lineno"> 332</span>&#160;</div>
  389. <div class="line"><a name="l00333"></a><span class="lineno"><a class="line" href="classgrpc_1_1_server_async_reader.html#a4407f30ef2dbce2b650824536a6f76fb"> 333</a></span>&#160; <span class="keywordtype">void</span> <a class="code" href="classgrpc_1_1_server_async_reader.html#a4407f30ef2dbce2b650824536a6f76fb">FinishWithError</a>(<span class="keyword">const</span> <a class="code" href="classgrpc_1_1_status.html">Status</a>&amp; status, <span class="keywordtype">void</span>* tag) {</div>
  390. <div class="line"><a name="l00334"></a><span class="lineno"> 334</span>&#160; GPR_ASSERT(!status.<a class="code" href="classgrpc_1_1_status.html#a1f5b65c54d4e6dd502897e36040714dc">ok</a>());</div>
  391. <div class="line"><a name="l00335"></a><span class="lineno"> 335</span>&#160; finish_ops_.set_output_tag(tag);</div>
  392. <div class="line"><a name="l00336"></a><span class="lineno"> 336</span>&#160; <span class="keywordflow">if</span> (!ctx_-&gt;sent_initial_metadata_) {</div>
  393. <div class="line"><a name="l00337"></a><span class="lineno"> 337</span>&#160; finish_ops_.SendInitialMetadata(ctx_-&gt;initial_metadata_);</div>
  394. <div class="line"><a name="l00338"></a><span class="lineno"> 338</span>&#160; ctx_-&gt;sent_initial_metadata_ = <span class="keyword">true</span>;</div>
  395. <div class="line"><a name="l00339"></a><span class="lineno"> 339</span>&#160; }</div>
  396. <div class="line"><a name="l00340"></a><span class="lineno"> 340</span>&#160; finish_ops_.ServerSendStatus(ctx_-&gt;trailing_metadata_, status);</div>
  397. <div class="line"><a name="l00341"></a><span class="lineno"> 341</span>&#160; call_.<a class="code" href="classgrpc_1_1_call.html#a78ca141a1008fbbb122ee4de076edcc4">PerformOps</a>(&amp;finish_ops_);</div>
  398. <div class="line"><a name="l00342"></a><span class="lineno"> 342</span>&#160; }</div>
  399. <div class="line"><a name="l00343"></a><span class="lineno"> 343</span>&#160;</div>
  400. <div class="line"><a name="l00344"></a><span class="lineno"> 344</span>&#160; <span class="keyword">private</span>:</div>
  401. <div class="line"><a name="l00345"></a><span class="lineno"> 345</span>&#160; <span class="keywordtype">void</span> BindCall(<a class="code" href="classgrpc_1_1_call.html">Call</a>* call) <a class="code" href="impl_2codegen_2config_8h.html#a9a884d706be26697c9c892365a3402a9">GRPC_OVERRIDE</a> { call_ = *call; }</div>
  402. <div class="line"><a name="l00346"></a><span class="lineno"> 346</span>&#160;</div>
  403. <div class="line"><a name="l00347"></a><span class="lineno"> 347</span>&#160; Call call_;</div>
  404. <div class="line"><a name="l00348"></a><span class="lineno"> 348</span>&#160; ServerContext* ctx_;</div>
  405. <div class="line"><a name="l00349"></a><span class="lineno"> 349</span>&#160; CallOpSet&lt;CallOpSendInitialMetadata&gt; meta_ops_;</div>
  406. <div class="line"><a name="l00350"></a><span class="lineno"> 350</span>&#160; CallOpSet&lt;CallOpRecvMessage&lt;R&gt;&gt; read_ops_;</div>
  407. <div class="line"><a name="l00351"></a><span class="lineno"> 351</span>&#160; CallOpSet&lt;CallOpSendInitialMetadata, CallOpSendMessage,</div>
  408. <div class="line"><a name="l00352"></a><span class="lineno"> 352</span>&#160; CallOpServerSendStatus&gt; finish_ops_;</div>
  409. <div class="line"><a name="l00353"></a><span class="lineno"> 353</span>&#160;};</div>
  410. <div class="line"><a name="l00354"></a><span class="lineno"> 354</span>&#160;</div>
  411. <div class="line"><a name="l00355"></a><span class="lineno"> 355</span>&#160;<span class="keyword">template</span> &lt;<span class="keyword">class</span> W&gt;</div>
  412. <div class="line"><a name="l00356"></a><span class="lineno"><a class="line" href="classgrpc_1_1_server_async_writer.html"> 356</a></span>&#160;<span class="keyword">class </span><a class="code" href="classgrpc_1_1_server_async_writer.html">ServerAsyncWriter</a> <a class="code" href="impl_2codegen_2config_8h.html#ab2216aa6e0ffe505e1ec362a9621a7f9">GRPC_FINAL</a> : <span class="keyword">public</span> <a class="code" href="classgrpc_1_1_server_async_streaming_interface.html">ServerAsyncStreamingInterface</a>,</div>
  413. <div class="line"><a name="l00357"></a><span class="lineno"> 357</span>&#160; <span class="keyword">public</span> <a class="code" href="classgrpc_1_1_async_writer_interface.html">AsyncWriterInterface</a>&lt;W&gt; {</div>
  414. <div class="line"><a name="l00358"></a><span class="lineno"> 358</span>&#160; <span class="keyword">public</span>:</div>
  415. <div class="line"><a name="l00359"></a><span class="lineno"><a class="line" href="classgrpc_1_1_server_async_writer.html#aa841b99fddf9ce347b9c617058f179f2"> 359</a></span>&#160; <span class="keyword">explicit</span> <a class="code" href="classgrpc_1_1_server_async_writer.html#aa841b99fddf9ce347b9c617058f179f2">ServerAsyncWriter</a>(<a class="code" href="classgrpc_1_1_server_context.html">ServerContext</a>* ctx)</div>
  416. <div class="line"><a name="l00360"></a><span class="lineno"> 360</span>&#160; : call_(nullptr, nullptr, nullptr), ctx_(ctx) {}</div>
  417. <div class="line"><a name="l00361"></a><span class="lineno"> 361</span>&#160;</div>
  418. <div class="line"><a name="l00362"></a><span class="lineno"><a class="line" href="classgrpc_1_1_server_async_writer.html#ad3a6ab6a46639131770efd0149d04455"> 362</a></span>&#160; <span class="keywordtype">void</span> <a class="code" href="classgrpc_1_1_server_async_writer.html#ad3a6ab6a46639131770efd0149d04455">SendInitialMetadata</a>(<span class="keywordtype">void</span>* tag) <a class="code" href="impl_2codegen_2config_8h.html#a9a884d706be26697c9c892365a3402a9">GRPC_OVERRIDE</a> {</div>
  419. <div class="line"><a name="l00363"></a><span class="lineno"> 363</span>&#160; GPR_ASSERT(!ctx_-&gt;sent_initial_metadata_);</div>
  420. <div class="line"><a name="l00364"></a><span class="lineno"> 364</span>&#160;</div>
  421. <div class="line"><a name="l00365"></a><span class="lineno"> 365</span>&#160; meta_ops_.set_output_tag(tag);</div>
  422. <div class="line"><a name="l00366"></a><span class="lineno"> 366</span>&#160; meta_ops_.SendInitialMetadata(ctx_-&gt;initial_metadata_);</div>
  423. <div class="line"><a name="l00367"></a><span class="lineno"> 367</span>&#160; ctx_-&gt;sent_initial_metadata_ = <span class="keyword">true</span>;</div>
  424. <div class="line"><a name="l00368"></a><span class="lineno"> 368</span>&#160; call_.<a class="code" href="classgrpc_1_1_call.html#a78ca141a1008fbbb122ee4de076edcc4">PerformOps</a>(&amp;meta_ops_);</div>
  425. <div class="line"><a name="l00369"></a><span class="lineno"> 369</span>&#160; }</div>
  426. <div class="line"><a name="l00370"></a><span class="lineno"> 370</span>&#160;</div>
  427. <div class="line"><a name="l00371"></a><span class="lineno"><a class="line" href="classgrpc_1_1_server_async_writer.html#a7027a65f3d84ff275b130cf9a0f170f5"> 371</a></span>&#160; <span class="keywordtype">void</span> <a class="code" href="classgrpc_1_1_server_async_writer.html#a7027a65f3d84ff275b130cf9a0f170f5">Write</a>(<span class="keyword">const</span> W&amp; msg, <span class="keywordtype">void</span>* tag) <a class="code" href="impl_2codegen_2config_8h.html#a9a884d706be26697c9c892365a3402a9">GRPC_OVERRIDE</a> {</div>
  428. <div class="line"><a name="l00372"></a><span class="lineno"> 372</span>&#160; write_ops_.set_output_tag(tag);</div>
  429. <div class="line"><a name="l00373"></a><span class="lineno"> 373</span>&#160; <span class="keywordflow">if</span> (!ctx_-&gt;sent_initial_metadata_) {</div>
  430. <div class="line"><a name="l00374"></a><span class="lineno"> 374</span>&#160; write_ops_.SendInitialMetadata(ctx_-&gt;initial_metadata_);</div>
  431. <div class="line"><a name="l00375"></a><span class="lineno"> 375</span>&#160; ctx_-&gt;sent_initial_metadata_ = <span class="keyword">true</span>;</div>
  432. <div class="line"><a name="l00376"></a><span class="lineno"> 376</span>&#160; }</div>
  433. <div class="line"><a name="l00377"></a><span class="lineno"> 377</span>&#160; <span class="comment">// TODO(ctiller): don&#39;t assert</span></div>
  434. <div class="line"><a name="l00378"></a><span class="lineno"> 378</span>&#160; GPR_ASSERT(write_ops_.SendMessage(msg).ok());</div>
  435. <div class="line"><a name="l00379"></a><span class="lineno"> 379</span>&#160; call_.<a class="code" href="classgrpc_1_1_call.html#a78ca141a1008fbbb122ee4de076edcc4">PerformOps</a>(&amp;write_ops_);</div>
  436. <div class="line"><a name="l00380"></a><span class="lineno"> 380</span>&#160; }</div>
  437. <div class="line"><a name="l00381"></a><span class="lineno"> 381</span>&#160;</div>
  438. <div class="line"><a name="l00382"></a><span class="lineno"><a class="line" href="classgrpc_1_1_server_async_writer.html#afbb050c198cbbc7f91f9f7fb8bf8c004"> 382</a></span>&#160; <span class="keywordtype">void</span> <a class="code" href="classgrpc_1_1_server_async_writer.html#afbb050c198cbbc7f91f9f7fb8bf8c004">Finish</a>(<span class="keyword">const</span> <a class="code" href="classgrpc_1_1_status.html">Status</a>&amp; status, <span class="keywordtype">void</span>* tag) {</div>
  439. <div class="line"><a name="l00383"></a><span class="lineno"> 383</span>&#160; finish_ops_.set_output_tag(tag);</div>
  440. <div class="line"><a name="l00384"></a><span class="lineno"> 384</span>&#160; <span class="keywordflow">if</span> (!ctx_-&gt;sent_initial_metadata_) {</div>
  441. <div class="line"><a name="l00385"></a><span class="lineno"> 385</span>&#160; finish_ops_.SendInitialMetadata(ctx_-&gt;initial_metadata_);</div>
  442. <div class="line"><a name="l00386"></a><span class="lineno"> 386</span>&#160; ctx_-&gt;sent_initial_metadata_ = <span class="keyword">true</span>;</div>
  443. <div class="line"><a name="l00387"></a><span class="lineno"> 387</span>&#160; }</div>
  444. <div class="line"><a name="l00388"></a><span class="lineno"> 388</span>&#160; finish_ops_.ServerSendStatus(ctx_-&gt;trailing_metadata_, status);</div>
  445. <div class="line"><a name="l00389"></a><span class="lineno"> 389</span>&#160; call_.<a class="code" href="classgrpc_1_1_call.html#a78ca141a1008fbbb122ee4de076edcc4">PerformOps</a>(&amp;finish_ops_);</div>
  446. <div class="line"><a name="l00390"></a><span class="lineno"> 390</span>&#160; }</div>
  447. <div class="line"><a name="l00391"></a><span class="lineno"> 391</span>&#160;</div>
  448. <div class="line"><a name="l00392"></a><span class="lineno"> 392</span>&#160; <span class="keyword">private</span>:</div>
  449. <div class="line"><a name="l00393"></a><span class="lineno"> 393</span>&#160; <span class="keywordtype">void</span> BindCall(<a class="code" href="classgrpc_1_1_call.html">Call</a>* call) <a class="code" href="impl_2codegen_2config_8h.html#a9a884d706be26697c9c892365a3402a9">GRPC_OVERRIDE</a> { call_ = *call; }</div>
  450. <div class="line"><a name="l00394"></a><span class="lineno"> 394</span>&#160;</div>
  451. <div class="line"><a name="l00395"></a><span class="lineno"> 395</span>&#160; Call call_;</div>
  452. <div class="line"><a name="l00396"></a><span class="lineno"> 396</span>&#160; ServerContext* ctx_;</div>
  453. <div class="line"><a name="l00397"></a><span class="lineno"> 397</span>&#160; CallOpSet&lt;CallOpSendInitialMetadata&gt; meta_ops_;</div>
  454. <div class="line"><a name="l00398"></a><span class="lineno"> 398</span>&#160; CallOpSet&lt;CallOpSendInitialMetadata, CallOpSendMessage&gt; write_ops_;</div>
  455. <div class="line"><a name="l00399"></a><span class="lineno"> 399</span>&#160; CallOpSet&lt;CallOpSendInitialMetadata, CallOpServerSendStatus&gt; finish_ops_;</div>
  456. <div class="line"><a name="l00400"></a><span class="lineno"> 400</span>&#160;};</div>
  457. <div class="line"><a name="l00401"></a><span class="lineno"> 401</span>&#160;</div>
  458. <div class="line"><a name="l00403"></a><span class="lineno"> 403</span>&#160;<span class="keyword">template</span> &lt;<span class="keyword">class</span> W, <span class="keyword">class</span> R&gt;</div>
  459. <div class="line"><a name="l00404"></a><span class="lineno"><a class="line" href="classgrpc_1_1_server_async_reader_writer.html"> 404</a></span>&#160;<span class="keyword">class </span><a class="code" href="classgrpc_1_1_server_async_reader_writer.html">ServerAsyncReaderWriter</a> <a class="code" href="impl_2codegen_2config_8h.html#ab2216aa6e0ffe505e1ec362a9621a7f9">GRPC_FINAL</a> : <span class="keyword">public</span> <a class="code" href="classgrpc_1_1_server_async_streaming_interface.html">ServerAsyncStreamingInterface</a>,</div>
  460. <div class="line"><a name="l00405"></a><span class="lineno"> 405</span>&#160; <span class="keyword">public</span> <a class="code" href="classgrpc_1_1_async_writer_interface.html">AsyncWriterInterface</a>&lt;W&gt;,</div>
  461. <div class="line"><a name="l00406"></a><span class="lineno"> 406</span>&#160; <span class="keyword">public</span> <a class="code" href="classgrpc_1_1_async_reader_interface.html">AsyncReaderInterface</a>&lt;R&gt; {</div>
  462. <div class="line"><a name="l00407"></a><span class="lineno"> 407</span>&#160; <span class="keyword">public</span>:</div>
  463. <div class="line"><a name="l00408"></a><span class="lineno"><a class="line" href="classgrpc_1_1_server_async_reader_writer.html#a6471b2baeaad0a1952628c67f948a703"> 408</a></span>&#160; <span class="keyword">explicit</span> <a class="code" href="classgrpc_1_1_server_async_reader_writer.html#a6471b2baeaad0a1952628c67f948a703">ServerAsyncReaderWriter</a>(<a class="code" href="classgrpc_1_1_server_context.html">ServerContext</a>* ctx)</div>
  464. <div class="line"><a name="l00409"></a><span class="lineno"> 409</span>&#160; : call_(nullptr, nullptr, nullptr), ctx_(ctx) {}</div>
  465. <div class="line"><a name="l00410"></a><span class="lineno"> 410</span>&#160;</div>
  466. <div class="line"><a name="l00411"></a><span class="lineno"><a class="line" href="classgrpc_1_1_server_async_reader_writer.html#a228b8570e133b732fdfb7bbf738ba3c4"> 411</a></span>&#160; <span class="keywordtype">void</span> <a class="code" href="classgrpc_1_1_server_async_reader_writer.html#a228b8570e133b732fdfb7bbf738ba3c4">SendInitialMetadata</a>(<span class="keywordtype">void</span>* tag) <a class="code" href="impl_2codegen_2config_8h.html#a9a884d706be26697c9c892365a3402a9">GRPC_OVERRIDE</a> {</div>
  467. <div class="line"><a name="l00412"></a><span class="lineno"> 412</span>&#160; GPR_ASSERT(!ctx_-&gt;sent_initial_metadata_);</div>
  468. <div class="line"><a name="l00413"></a><span class="lineno"> 413</span>&#160;</div>
  469. <div class="line"><a name="l00414"></a><span class="lineno"> 414</span>&#160; meta_ops_.set_output_tag(tag);</div>
  470. <div class="line"><a name="l00415"></a><span class="lineno"> 415</span>&#160; meta_ops_.SendInitialMetadata(ctx_-&gt;initial_metadata_);</div>
  471. <div class="line"><a name="l00416"></a><span class="lineno"> 416</span>&#160; ctx_-&gt;sent_initial_metadata_ = <span class="keyword">true</span>;</div>
  472. <div class="line"><a name="l00417"></a><span class="lineno"> 417</span>&#160; call_.<a class="code" href="classgrpc_1_1_call.html#a78ca141a1008fbbb122ee4de076edcc4">PerformOps</a>(&amp;meta_ops_);</div>
  473. <div class="line"><a name="l00418"></a><span class="lineno"> 418</span>&#160; }</div>
  474. <div class="line"><a name="l00419"></a><span class="lineno"> 419</span>&#160;</div>
  475. <div class="line"><a name="l00420"></a><span class="lineno"><a class="line" href="classgrpc_1_1_server_async_reader_writer.html#a2adbae40645434ad5f55823967998acc"> 420</a></span>&#160; <span class="keywordtype">void</span> <a class="code" href="classgrpc_1_1_server_async_reader_writer.html#a2adbae40645434ad5f55823967998acc">Read</a>(R* msg, <span class="keywordtype">void</span>* tag) <a class="code" href="impl_2codegen_2config_8h.html#a9a884d706be26697c9c892365a3402a9">GRPC_OVERRIDE</a> {</div>
  476. <div class="line"><a name="l00421"></a><span class="lineno"> 421</span>&#160; read_ops_.set_output_tag(tag);</div>
  477. <div class="line"><a name="l00422"></a><span class="lineno"> 422</span>&#160; read_ops_.RecvMessage(msg);</div>
  478. <div class="line"><a name="l00423"></a><span class="lineno"> 423</span>&#160; call_.<a class="code" href="classgrpc_1_1_call.html#a78ca141a1008fbbb122ee4de076edcc4">PerformOps</a>(&amp;read_ops_);</div>
  479. <div class="line"><a name="l00424"></a><span class="lineno"> 424</span>&#160; }</div>
  480. <div class="line"><a name="l00425"></a><span class="lineno"> 425</span>&#160;</div>
  481. <div class="line"><a name="l00426"></a><span class="lineno"><a class="line" href="classgrpc_1_1_server_async_reader_writer.html#a640c86c1d3a2e47c6efe6838d8954c82"> 426</a></span>&#160; <span class="keywordtype">void</span> <a class="code" href="classgrpc_1_1_server_async_reader_writer.html#a640c86c1d3a2e47c6efe6838d8954c82">Write</a>(<span class="keyword">const</span> W&amp; msg, <span class="keywordtype">void</span>* tag) <a class="code" href="impl_2codegen_2config_8h.html#a9a884d706be26697c9c892365a3402a9">GRPC_OVERRIDE</a> {</div>
  482. <div class="line"><a name="l00427"></a><span class="lineno"> 427</span>&#160; write_ops_.set_output_tag(tag);</div>
  483. <div class="line"><a name="l00428"></a><span class="lineno"> 428</span>&#160; <span class="keywordflow">if</span> (!ctx_-&gt;sent_initial_metadata_) {</div>
  484. <div class="line"><a name="l00429"></a><span class="lineno"> 429</span>&#160; write_ops_.SendInitialMetadata(ctx_-&gt;initial_metadata_);</div>
  485. <div class="line"><a name="l00430"></a><span class="lineno"> 430</span>&#160; ctx_-&gt;sent_initial_metadata_ = <span class="keyword">true</span>;</div>
  486. <div class="line"><a name="l00431"></a><span class="lineno"> 431</span>&#160; }</div>
  487. <div class="line"><a name="l00432"></a><span class="lineno"> 432</span>&#160; <span class="comment">// TODO(ctiller): don&#39;t assert</span></div>
  488. <div class="line"><a name="l00433"></a><span class="lineno"> 433</span>&#160; GPR_ASSERT(write_ops_.SendMessage(msg).ok());</div>
  489. <div class="line"><a name="l00434"></a><span class="lineno"> 434</span>&#160; call_.<a class="code" href="classgrpc_1_1_call.html#a78ca141a1008fbbb122ee4de076edcc4">PerformOps</a>(&amp;write_ops_);</div>
  490. <div class="line"><a name="l00435"></a><span class="lineno"> 435</span>&#160; }</div>
  491. <div class="line"><a name="l00436"></a><span class="lineno"> 436</span>&#160;</div>
  492. <div class="line"><a name="l00437"></a><span class="lineno"><a class="line" href="classgrpc_1_1_server_async_reader_writer.html#a8dba3391a9b4bd89446c6e3267194a2e"> 437</a></span>&#160; <span class="keywordtype">void</span> <a class="code" href="classgrpc_1_1_server_async_reader_writer.html#a8dba3391a9b4bd89446c6e3267194a2e">Finish</a>(<span class="keyword">const</span> <a class="code" href="classgrpc_1_1_status.html">Status</a>&amp; status, <span class="keywordtype">void</span>* tag) {</div>
  493. <div class="line"><a name="l00438"></a><span class="lineno"> 438</span>&#160; finish_ops_.set_output_tag(tag);</div>
  494. <div class="line"><a name="l00439"></a><span class="lineno"> 439</span>&#160; <span class="keywordflow">if</span> (!ctx_-&gt;sent_initial_metadata_) {</div>
  495. <div class="line"><a name="l00440"></a><span class="lineno"> 440</span>&#160; finish_ops_.SendInitialMetadata(ctx_-&gt;initial_metadata_);</div>
  496. <div class="line"><a name="l00441"></a><span class="lineno"> 441</span>&#160; ctx_-&gt;sent_initial_metadata_ = <span class="keyword">true</span>;</div>
  497. <div class="line"><a name="l00442"></a><span class="lineno"> 442</span>&#160; }</div>
  498. <div class="line"><a name="l00443"></a><span class="lineno"> 443</span>&#160; finish_ops_.ServerSendStatus(ctx_-&gt;trailing_metadata_, status);</div>
  499. <div class="line"><a name="l00444"></a><span class="lineno"> 444</span>&#160; call_.<a class="code" href="classgrpc_1_1_call.html#a78ca141a1008fbbb122ee4de076edcc4">PerformOps</a>(&amp;finish_ops_);</div>
  500. <div class="line"><a name="l00445"></a><span class="lineno"> 445</span>&#160; }</div>
  501. <div class="line"><a name="l00446"></a><span class="lineno"> 446</span>&#160;</div>
  502. <div class="line"><a name="l00447"></a><span class="lineno"> 447</span>&#160; <span class="keyword">private</span>:</div>
  503. <div class="line"><a name="l00448"></a><span class="lineno"><a class="line" href="classgrpc_1_1_server_async_reader_writer.html#a8c3fa4c066981aae114e41c3f9340144"> 448</a></span>&#160; <span class="keyword">friend</span> class ::grpc::Server;</div>
  504. <div class="line"><a name="l00449"></a><span class="lineno"> 449</span>&#160;</div>
  505. <div class="line"><a name="l00450"></a><span class="lineno"> 450</span>&#160; <span class="keywordtype">void</span> BindCall(<a class="code" href="classgrpc_1_1_call.html">Call</a>* call) <a class="code" href="impl_2codegen_2config_8h.html#a9a884d706be26697c9c892365a3402a9">GRPC_OVERRIDE</a> { call_ = *call; }</div>
  506. <div class="line"><a name="l00451"></a><span class="lineno"> 451</span>&#160;</div>
  507. <div class="line"><a name="l00452"></a><span class="lineno"> 452</span>&#160; <a class="code" href="classgrpc_1_1_call.html">Call</a> call_;</div>
  508. <div class="line"><a name="l00453"></a><span class="lineno"> 453</span>&#160; <a class="code" href="classgrpc_1_1_server_context.html">ServerContext</a>* ctx_;</div>
  509. <div class="line"><a name="l00454"></a><span class="lineno"> 454</span>&#160; <a class="code" href="classgrpc_1_1_call_op_set.html">CallOpSet&lt;CallOpSendInitialMetadata&gt;</a> meta_ops_;</div>
  510. <div class="line"><a name="l00455"></a><span class="lineno"> 455</span>&#160; <a class="code" href="classgrpc_1_1_call_op_set.html">CallOpSet&lt;CallOpRecvMessage&lt;R&gt;</a>&gt; read_ops_;</div>
  511. <div class="line"><a name="l00456"></a><span class="lineno"> 456</span>&#160; <a class="code" href="classgrpc_1_1_call_op_set.html">CallOpSet&lt;CallOpSendInitialMetadata, CallOpSendMessage&gt;</a> write_ops_;</div>
  512. <div class="line"><a name="l00457"></a><span class="lineno"> 457</span>&#160; <a class="code" href="classgrpc_1_1_call_op_set.html">CallOpSet&lt;CallOpSendInitialMetadata, CallOpServerSendStatus&gt;</a> finish_ops_;</div>
  513. <div class="line"><a name="l00458"></a><span class="lineno"> 458</span>&#160;};</div>
  514. <div class="line"><a name="l00459"></a><span class="lineno"> 459</span>&#160;</div>
  515. <div class="line"><a name="l00460"></a><span class="lineno"> 460</span>&#160;} <span class="comment">// namespace grpc</span></div>
  516. <div class="line"><a name="l00461"></a><span class="lineno"> 461</span>&#160;</div>
  517. <div class="line"><a name="l00462"></a><span class="lineno"> 462</span>&#160;<span class="preprocessor">#endif // GRPCXX_IMPL_CODEGEN_ASYNC_STREAM_H</span></div>
  518. <div class="ttc" id="classgrpc_1_1_client_async_streaming_interface_html"><div class="ttname"><a href="classgrpc_1_1_client_async_streaming_interface.html">grpc::ClientAsyncStreamingInterface</a></div><div class="ttdoc">Common interface for all client side asynchronous streaming. </div><div class="ttdef"><b>Definition:</b> async_stream.h:48</div></div>
  519. <div class="ttc" id="classgrpc_1_1_client_async_reader_writer_html"><div class="ttname"><a href="classgrpc_1_1_client_async_reader_writer.html">grpc::ClientAsyncReaderWriter</a></div><div class="ttdef"><b>Definition:</b> async_stream.h:233</div></div>
  520. <div class="ttc" id="classgrpc_1_1_server_async_reader_writer_html_a228b8570e133b732fdfb7bbf738ba3c4"><div class="ttname"><a href="classgrpc_1_1_server_async_reader_writer.html#a228b8570e133b732fdfb7bbf738ba3c4">grpc::ServerAsyncReaderWriter::SendInitialMetadata</a></div><div class="ttdeci">void SendInitialMetadata(void *tag) GRPC_OVERRIDE</div><div class="ttdef"><b>Definition:</b> async_stream.h:411</div></div>
  521. <div class="ttc" id="classgrpc_1_1_client_async_writer_html_a544f9e4c310b251bf3c7b84fd035d20a"><div class="ttname"><a href="classgrpc_1_1_client_async_writer.html#a544f9e4c310b251bf3c7b84fd035d20a">grpc::ClientAsyncWriter::Write</a></div><div class="ttdeci">void Write(const W &amp;msg, void *tag) GRPC_OVERRIDE</div><div class="ttdoc">Request the writing of msg with identifying tag tag. </div><div class="ttdef"><b>Definition:</b> async_stream.h:187</div></div>
  522. <div class="ttc" id="classgrpc_1_1_client_async_writer_html_af9fbf77049c3e5402913c0edeccf3d47"><div class="ttname"><a href="classgrpc_1_1_client_async_writer.html#af9fbf77049c3e5402913c0edeccf3d47">grpc::ClientAsyncWriter::WritesDone</a></div><div class="ttdeci">void WritesDone(void *tag) GRPC_OVERRIDE</div><div class="ttdoc">Signal the client is done with the writes. </div><div class="ttdef"><b>Definition:</b> async_stream.h:194</div></div>
  523. <div class="ttc" id="classgrpc_1_1_server_async_reader_writer_html_a2adbae40645434ad5f55823967998acc"><div class="ttname"><a href="classgrpc_1_1_server_async_reader_writer.html#a2adbae40645434ad5f55823967998acc">grpc::ServerAsyncReaderWriter::Read</a></div><div class="ttdeci">void Read(R *msg, void *tag) GRPC_OVERRIDE</div><div class="ttdoc">Read a message of type R into msg. </div><div class="ttdef"><b>Definition:</b> async_stream.h:420</div></div>
  524. <div class="ttc" id="codegen_2service__type_8h_html"><div class="ttname"><a href="codegen_2service__type_8h.html">service_type.h</a></div></div>
  525. <div class="ttc" id="classgrpc_1_1_server_async_writer_html_ad3a6ab6a46639131770efd0149d04455"><div class="ttname"><a href="classgrpc_1_1_server_async_writer.html#ad3a6ab6a46639131770efd0149d04455">grpc::ServerAsyncWriter::SendInitialMetadata</a></div><div class="ttdeci">void SendInitialMetadata(void *tag) GRPC_OVERRIDE</div><div class="ttdef"><b>Definition:</b> async_stream.h:362</div></div>
  526. <div class="ttc" id="classgrpc_1_1_client_async_reader_writer_html_aebfcea780f028eb345887b6364f1e45a"><div class="ttname"><a href="classgrpc_1_1_client_async_reader_writer.html#aebfcea780f028eb345887b6364f1e45a">grpc::ClientAsyncReaderWriter::ReadInitialMetadata</a></div><div class="ttdeci">void ReadInitialMetadata(void *tag) GRPC_OVERRIDE</div><div class="ttdoc">Request notification of the reading of the initial metadata. </div><div class="ttdef"><b>Definition:</b> async_stream.h:245</div></div>
  527. <div class="ttc" id="classgrpc_1_1_client_async_reader_writer_interface_html_a878193880df68ab969b697f1fcd7dbc3"><div class="ttname"><a href="classgrpc_1_1_client_async_reader_writer_interface.html#a878193880df68ab969b697f1fcd7dbc3">grpc::ClientAsyncReaderWriterInterface::WritesDone</a></div><div class="ttdeci">virtual void WritesDone(void *tag)=0</div><div class="ttdoc">Signal the client is done with the writes. </div></div>
  528. <div class="ttc" id="classgrpc_1_1_call_op_client_recv_status_html"><div class="ttname"><a href="classgrpc_1_1_call_op_client_recv_status.html">grpc::CallOpClientRecvStatus</a></div><div class="ttdef"><b>Definition:</b> call.h:431</div></div>
  529. <div class="ttc" id="classgrpc_1_1_async_writer_interface_html_a40c1091ac5cb5243c874da725ae291b4"><div class="ttname"><a href="classgrpc_1_1_async_writer_interface.html#a40c1091ac5cb5243c874da725ae291b4">grpc::AsyncWriterInterface::Write</a></div><div class="ttdeci">virtual void Write(const W &amp;msg, void *tag)=0</div><div class="ttdoc">Request the writing of msg with identifying tag tag. </div></div>
  530. <div class="ttc" id="classgrpc_1_1_server_async_reader_writer_html"><div class="ttname"><a href="classgrpc_1_1_server_async_reader_writer.html">grpc::ServerAsyncReaderWriter</a></div><div class="ttdoc">Server-side interface for asynchronous bi-directional streaming. </div><div class="ttdef"><b>Definition:</b> async_stream.h:404</div></div>
  531. <div class="ttc" id="impl_2codegen_2status_8h_html"><div class="ttname"><a href="impl_2codegen_2status_8h.html">status.h</a></div></div>
  532. <div class="ttc" id="classgrpc_1_1_server_async_streaming_interface_html"><div class="ttname"><a href="classgrpc_1_1_server_async_streaming_interface.html">grpc::ServerAsyncStreamingInterface</a></div><div class="ttdef"><b>Definition:</b> service_type.h:52</div></div>
  533. <div class="ttc" id="classgrpc_1_1_server_async_writer_html_a7027a65f3d84ff275b130cf9a0f170f5"><div class="ttname"><a href="classgrpc_1_1_server_async_writer.html#a7027a65f3d84ff275b130cf9a0f170f5">grpc::ServerAsyncWriter::Write</a></div><div class="ttdeci">void Write(const W &amp;msg, void *tag) GRPC_OVERRIDE</div><div class="ttdoc">Request the writing of msg with identifying tag tag. </div><div class="ttdef"><b>Definition:</b> async_stream.h:371</div></div>
  534. <div class="ttc" id="impl_2codegen_2server__context_8h_html"><div class="ttname"><a href="impl_2codegen_2server__context_8h.html">server_context.h</a></div></div>
  535. <div class="ttc" id="channel__interface_8h_html"><div class="ttname"><a href="channel__interface_8h.html">channel_interface.h</a></div></div>
  536. <div class="ttc" id="classgrpc_1_1_client_async_reader_writer_html_a6f4dfc5fdd441b4997d5f1226eb32dbe"><div class="ttname"><a href="classgrpc_1_1_client_async_reader_writer.html#a6f4dfc5fdd441b4997d5f1226eb32dbe">grpc::ClientAsyncReaderWriter::Read</a></div><div class="ttdeci">void Read(R *msg, void *tag) GRPC_OVERRIDE</div><div class="ttdoc">Read a message of type R into msg. </div><div class="ttdef"><b>Definition:</b> async_stream.h:253</div></div>
  537. <div class="ttc" id="classgrpc_1_1_server_async_reader_html_ac60c1f8d5373644f952377096f1a5b2f"><div class="ttname"><a href="classgrpc_1_1_server_async_reader.html#ac60c1f8d5373644f952377096f1a5b2f">grpc::ServerAsyncReader::Read</a></div><div class="ttdeci">void Read(R *msg, void *tag) GRPC_OVERRIDE</div><div class="ttdoc">Read a message of type R into msg. </div><div class="ttdef"><b>Definition:</b> async_stream.h:311</div></div>
  538. <div class="ttc" id="classgrpc_1_1_client_async_writer_interface_html_a488d42d85f8e34902401e013572ff822"><div class="ttname"><a href="classgrpc_1_1_client_async_writer_interface.html#a488d42d85f8e34902401e013572ff822">grpc::ClientAsyncWriterInterface::WritesDone</a></div><div class="ttdeci">virtual void WritesDone(void *tag)=0</div><div class="ttdoc">Signal the client is done with the writes. </div></div>
  539. <div class="ttc" id="classgrpc_1_1_client_context_html"><div class="ttname"><a href="classgrpc_1_1_client_context.html">grpc::ClientContext</a></div><div class="ttdef"><b>Definition:</b> client_context.h:152</div></div>
  540. <div class="ttc" id="classgrpc_1_1_server_async_reader_html_a4407f30ef2dbce2b650824536a6f76fb"><div class="ttname"><a href="classgrpc_1_1_server_async_reader.html#a4407f30ef2dbce2b650824536a6f76fb">grpc::ServerAsyncReader::FinishWithError</a></div><div class="ttdeci">void FinishWithError(const Status &amp;status, void *tag)</div><div class="ttdef"><b>Definition:</b> async_stream.h:333</div></div>
  541. <div class="ttc" id="classgrpc_1_1_server_async_writer_html"><div class="ttname"><a href="classgrpc_1_1_server_async_writer.html">grpc::ServerAsyncWriter</a></div><div class="ttdef"><b>Definition:</b> async_stream.h:356</div></div>
  542. <div class="ttc" id="classgrpc_1_1_client_async_writer_html_ad4903b1736b423c076bac8e23db345f6"><div class="ttname"><a href="classgrpc_1_1_client_async_writer.html#ad4903b1736b423c076bac8e23db345f6">grpc::ClientAsyncWriter::ClientAsyncWriter</a></div><div class="ttdeci">ClientAsyncWriter(ChannelInterface *channel, CompletionQueue *cq, const RpcMethod &amp;method, ClientContext *context, R *response, void *tag)</div><div class="ttdef"><b>Definition:</b> async_stream.h:168</div></div>
  543. <div class="ttc" id="classgrpc_1_1_async_reader_interface_html_ac7845d2df90fb380008aadb7f5f2f379"><div class="ttname"><a href="classgrpc_1_1_async_reader_interface.html#ac7845d2df90fb380008aadb7f5f2f379">grpc::AsyncReaderInterface::~AsyncReaderInterface</a></div><div class="ttdeci">virtual ~AsyncReaderInterface()</div><div class="ttdef"><b>Definition:</b> async_stream.h:69</div></div>
  544. <div class="ttc" id="classgrpc_1_1_server_async_reader_writer_html_a6471b2baeaad0a1952628c67f948a703"><div class="ttname"><a href="classgrpc_1_1_server_async_reader_writer.html#a6471b2baeaad0a1952628c67f948a703">grpc::ServerAsyncReaderWriter::ServerAsyncReaderWriter</a></div><div class="ttdeci">ServerAsyncReaderWriter(ServerContext *ctx)</div><div class="ttdef"><b>Definition:</b> async_stream.h:408</div></div>
  545. <div class="ttc" id="classgrpc_1_1_client_async_reader_writer_html_a0511a6da96294a181471688be7765044"><div class="ttname"><a href="classgrpc_1_1_client_async_reader_writer.html#a0511a6da96294a181471688be7765044">grpc::ClientAsyncReaderWriter::ClientAsyncReaderWriter</a></div><div class="ttdeci">ClientAsyncReaderWriter(ChannelInterface *channel, CompletionQueue *cq, const RpcMethod &amp;method, ClientContext *context, void *tag)</div><div class="ttdef"><b>Definition:</b> async_stream.h:236</div></div>
  546. <div class="ttc" id="classgrpc_1_1_client_async_reader_interface_html"><div class="ttname"><a href="classgrpc_1_1_client_async_reader_interface.html">grpc::ClientAsyncReaderInterface</a></div><div class="ttdef"><b>Definition:</b> async_stream.h:97</div></div>
  547. <div class="ttc" id="classgrpc_1_1_call_html"><div class="ttname"><a href="classgrpc_1_1_call.html">grpc::Call</a></div><div class="ttdef"><b>Definition:</b> call.h:576</div></div>
  548. <div class="ttc" id="classgrpc_1_1_client_async_reader_writer_html_a585ad2f181b1b5041349243861f15994"><div class="ttname"><a href="classgrpc_1_1_client_async_reader_writer.html#a585ad2f181b1b5041349243861f15994">grpc::ClientAsyncReaderWriter::Write</a></div><div class="ttdeci">void Write(const W &amp;msg, void *tag) GRPC_OVERRIDE</div><div class="ttdoc">Request the writing of msg with identifying tag tag. </div><div class="ttdef"><b>Definition:</b> async_stream.h:262</div></div>
  549. <div class="ttc" id="classgrpc_1_1_client_async_reader_writer_interface_html"><div class="ttname"><a href="classgrpc_1_1_client_async_reader_writer_interface.html">grpc::ClientAsyncReaderWriterInterface</a></div><div class="ttdoc">Client-side interface for asynchronous bi-directional streaming. </div><div class="ttdef"><b>Definition:</b> async_stream.h:222</div></div>
  550. <div class="ttc" id="classgrpc_1_1_channel_interface_html"><div class="ttname"><a href="classgrpc_1_1_channel_interface.html">grpc::ChannelInterface</a></div><div class="ttdoc">Codegen interface for grpc::Channel. </div><div class="ttdef"><b>Definition:</b> channel_interface.h:64</div></div>
  551. <div class="ttc" id="classgrpc_1_1_server_async_writer_html_aa841b99fddf9ce347b9c617058f179f2"><div class="ttname"><a href="classgrpc_1_1_server_async_writer.html#aa841b99fddf9ce347b9c617058f179f2">grpc::ServerAsyncWriter::ServerAsyncWriter</a></div><div class="ttdeci">ServerAsyncWriter(ServerContext *ctx)</div><div class="ttdef"><b>Definition:</b> async_stream.h:359</div></div>
  552. <div class="ttc" id="classgrpc_1_1_client_async_writer_html_a1db45c4f5817db4f770c08dab64916c7"><div class="ttname"><a href="classgrpc_1_1_client_async_writer.html#a1db45c4f5817db4f770c08dab64916c7">grpc::ClientAsyncWriter::ReadInitialMetadata</a></div><div class="ttdeci">void ReadInitialMetadata(void *tag) GRPC_OVERRIDE</div><div class="ttdoc">Request notification of the reading of the initial metadata. </div><div class="ttdef"><b>Definition:</b> async_stream.h:179</div></div>
  553. <div class="ttc" id="classgrpc_1_1_async_writer_interface_html"><div class="ttname"><a href="classgrpc_1_1_async_writer_interface.html">grpc::AsyncWriterInterface</a></div><div class="ttdoc">An interface that can be fed a sequence of messages of type W. </div><div class="ttdef"><b>Definition:</b> async_stream.h:81</div></div>
  554. <div class="ttc" id="classgrpc_1_1_client_async_writer_html"><div class="ttname"><a href="classgrpc_1_1_client_async_writer.html">grpc::ClientAsyncWriter</a></div><div class="ttdef"><b>Definition:</b> async_stream.h:165</div></div>
  555. <div class="ttc" id="classgrpc_1_1_call_op_set_html"><div class="ttname"><a href="classgrpc_1_1_call_op_set.html">grpc::CallOpSet</a></div><div class="ttdoc">Primary implementaiton of CallOpSetInterface. </div><div class="ttdef"><b>Definition:</b> call.h:524</div></div>
  556. <div class="ttc" id="classgrpc_1_1_server_context_html"><div class="ttname"><a href="classgrpc_1_1_server_context.html">grpc::ServerContext</a></div><div class="ttdef"><b>Definition:</b> server_context.h:90</div></div>
  557. <div class="ttc" id="classgrpc_1_1_server_async_reader_html_aaa77b67709c07ab60bc190bce5ee9a59"><div class="ttname"><a href="classgrpc_1_1_server_async_reader.html#aaa77b67709c07ab60bc190bce5ee9a59">grpc::ServerAsyncReader::Finish</a></div><div class="ttdeci">void Finish(const W &amp;msg, const Status &amp;status, void *tag)</div><div class="ttdef"><b>Definition:</b> async_stream.h:317</div></div>
  558. <div class="ttc" id="classgrpc_1_1_completion_queue_html"><div class="ttname"><a href="classgrpc_1_1_completion_queue.html">grpc::CompletionQueue</a></div><div class="ttdoc">A thin wrapper around grpc_completion_queue (see / src/core/surface/completion_queue.h). </div><div class="ttdef"><b>Definition:</b> completion_queue.h:81</div></div>
  559. <div class="ttc" id="impl_2codegen_2config_8h_html_ab2216aa6e0ffe505e1ec362a9621a7f9"><div class="ttname"><a href="impl_2codegen_2config_8h.html#ab2216aa6e0ffe505e1ec362a9621a7f9">GRPC_FINAL</a></div><div class="ttdeci">#define GRPC_FINAL</div><div class="ttdef"><b>Definition:</b> config.h:71</div></div>
  560. <div class="ttc" id="classgrpc_1_1_client_async_streaming_interface_html_a103c33e82dbf1715749886c4249f3f28"><div class="ttname"><a href="classgrpc_1_1_client_async_streaming_interface.html#a103c33e82dbf1715749886c4249f3f28">grpc::ClientAsyncStreamingInterface::~ClientAsyncStreamingInterface</a></div><div class="ttdeci">virtual ~ClientAsyncStreamingInterface()</div><div class="ttdef"><b>Definition:</b> async_stream.h:50</div></div>
  561. <div class="ttc" id="classgrpc_1_1_client_async_writer_html_ad37af0a7fc27fc90e168fdb90eb52d8b"><div class="ttname"><a href="classgrpc_1_1_client_async_writer.html#ad37af0a7fc27fc90e168fdb90eb52d8b">grpc::ClientAsyncWriter::Finish</a></div><div class="ttdeci">void Finish(Status *status, void *tag) GRPC_OVERRIDE</div><div class="ttdoc">Request notification completion. </div><div class="ttdef"><b>Definition:</b> async_stream.h:200</div></div>
  562. <div class="ttc" id="classgrpc_1_1_server_async_writer_html_afbb050c198cbbc7f91f9f7fb8bf8c004"><div class="ttname"><a href="classgrpc_1_1_server_async_writer.html#afbb050c198cbbc7f91f9f7fb8bf8c004">grpc::ServerAsyncWriter::Finish</a></div><div class="ttdeci">void Finish(const Status &amp;status, void *tag)</div><div class="ttdef"><b>Definition:</b> async_stream.h:382</div></div>
  563. <div class="ttc" id="classgrpc_1_1_client_async_streaming_interface_html_ad83bfe2febf4a6296b7d2646799b8174"><div class="ttname"><a href="classgrpc_1_1_client_async_streaming_interface.html#ad83bfe2febf4a6296b7d2646799b8174">grpc::ClientAsyncStreamingInterface::ReadInitialMetadata</a></div><div class="ttdeci">virtual void ReadInitialMetadata(void *tag)=0</div><div class="ttdoc">Request notification of the reading of the initial metadata. </div></div>
  564. <div class="ttc" id="classgrpc_1_1_rpc_method_html"><div class="ttname"><a href="classgrpc_1_1_rpc_method.html">grpc::RpcMethod</a></div><div class="ttdef"><b>Definition:</b> rpc_method.h:43</div></div>
  565. <div class="ttc" id="classgrpc_1_1_client_async_reader_html_a91bfabf65e2dc955b6983bc0ece5a73f"><div class="ttname"><a href="classgrpc_1_1_client_async_reader.html#a91bfabf65e2dc955b6983bc0ece5a73f">grpc::ClientAsyncReader::Finish</a></div><div class="ttdeci">void Finish(Status *status, void *tag) GRPC_OVERRIDE</div><div class="ttdoc">Request notification completion. </div><div class="ttdef"><b>Definition:</b> async_stream.h:134</div></div>
  566. <div class="ttc" id="classgrpc_1_1_call_html_a78ca141a1008fbbb122ee4de076edcc4"><div class="ttname"><a href="classgrpc_1_1_call.html#a78ca141a1008fbbb122ee4de076edcc4">grpc::Call::PerformOps</a></div><div class="ttdeci">void PerformOps(CallOpSetInterface *ops)</div></div>
  567. <div class="ttc" id="classgrpc_1_1_status_html_a1f5b65c54d4e6dd502897e36040714dc"><div class="ttname"><a href="classgrpc_1_1_status.html#a1f5b65c54d4e6dd502897e36040714dc">grpc::Status::ok</a></div><div class="ttdeci">bool ok() const </div><div class="ttdoc">Is the status OK? </div><div class="ttdef"><b>Definition:</b> status.h:67</div></div>
  568. <div class="ttc" id="classgrpc_1_1_status_html"><div class="ttname"><a href="classgrpc_1_1_status.html">grpc::Status</a></div><div class="ttdoc">Did it work? If it didn&#39;t, why? </div><div class="ttdef"><b>Definition:</b> status.h:45</div></div>
  569. <div class="ttc" id="classgrpc_1_1_server_async_reader_writer_html_a8dba3391a9b4bd89446c6e3267194a2e"><div class="ttname"><a href="classgrpc_1_1_server_async_reader_writer.html#a8dba3391a9b4bd89446c6e3267194a2e">grpc::ServerAsyncReaderWriter::Finish</a></div><div class="ttdeci">void Finish(const Status &amp;status, void *tag)</div><div class="ttdef"><b>Definition:</b> async_stream.h:437</div></div>
  570. <div class="ttc" id="classgrpc_1_1_server_async_reader_writer_html_a640c86c1d3a2e47c6efe6838d8954c82"><div class="ttname"><a href="classgrpc_1_1_server_async_reader_writer.html#a640c86c1d3a2e47c6efe6838d8954c82">grpc::ServerAsyncReaderWriter::Write</a></div><div class="ttdeci">void Write(const W &amp;msg, void *tag) GRPC_OVERRIDE</div><div class="ttdoc">Request the writing of msg with identifying tag tag. </div><div class="ttdef"><b>Definition:</b> async_stream.h:426</div></div>
  571. <div class="ttc" id="classgrpc_1_1_client_async_streaming_interface_html_afc1cfbd1514fea47088bc837bb578a24"><div class="ttname"><a href="classgrpc_1_1_client_async_streaming_interface.html#afc1cfbd1514fea47088bc837bb578a24">grpc::ClientAsyncStreamingInterface::Finish</a></div><div class="ttdeci">virtual void Finish(Status *status, void *tag)=0</div><div class="ttdoc">Request notification completion. </div></div>
  572. <div class="ttc" id="classgrpc_1_1_server_async_reader_html_a5d05028563e789203225c0ba548710b6"><div class="ttname"><a href="classgrpc_1_1_server_async_reader.html#a5d05028563e789203225c0ba548710b6">grpc::ServerAsyncReader::SendInitialMetadata</a></div><div class="ttdeci">void SendInitialMetadata(void *tag) GRPC_OVERRIDE</div><div class="ttdef"><b>Definition:</b> async_stream.h:302</div></div>
  573. <div class="ttc" id="codegen_2call_8h_html"><div class="ttname"><a href="codegen_2call_8h.html">call.h</a></div></div>
  574. <div class="ttc" id="classgrpc_1_1_client_async_reader_html_aaf9f76ba76be0a0144bbdf44d740731d"><div class="ttname"><a href="classgrpc_1_1_client_async_reader.html#aaf9f76ba76be0a0144bbdf44d740731d">grpc::ClientAsyncReader::Read</a></div><div class="ttdeci">void Read(R *msg, void *tag) GRPC_OVERRIDE</div><div class="ttdoc">Read a message of type R into msg. </div><div class="ttdef"><b>Definition:</b> async_stream.h:125</div></div>
  575. <div class="ttc" id="classgrpc_1_1_client_async_reader_html"><div class="ttname"><a href="classgrpc_1_1_client_async_reader.html">grpc::ClientAsyncReader</a></div><div class="ttdef"><b>Definition:</b> async_stream.h:101</div></div>
  576. <div class="ttc" id="classgrpc_1_1_async_writer_interface_html_a94cc9e4ed13c8fe4a1d883d465477ddd"><div class="ttname"><a href="classgrpc_1_1_async_writer_interface.html#a94cc9e4ed13c8fe4a1d883d465477ddd">grpc::AsyncWriterInterface::~AsyncWriterInterface</a></div><div class="ttdeci">virtual ~AsyncWriterInterface()</div><div class="ttdef"><b>Definition:</b> async_stream.h:83</div></div>
  577. <div class="ttc" id="impl_2codegen_2config_8h_html_a9a884d706be26697c9c892365a3402a9"><div class="ttname"><a href="impl_2codegen_2config_8h.html#a9a884d706be26697c9c892365a3402a9">GRPC_OVERRIDE</a></div><div class="ttdeci">#define GRPC_OVERRIDE</div><div class="ttdef"><b>Definition:</b> config.h:77</div></div>
  578. <div class="ttc" id="classgrpc_1_1_client_async_reader_writer_html_aa0b94fec5a1b7c22e4db8046b1f031cc"><div class="ttname"><a href="classgrpc_1_1_client_async_reader_writer.html#aa0b94fec5a1b7c22e4db8046b1f031cc">grpc::ClientAsyncReaderWriter::Finish</a></div><div class="ttdeci">void Finish(Status *status, void *tag) GRPC_OVERRIDE</div><div class="ttdoc">Request notification completion. </div><div class="ttdef"><b>Definition:</b> async_stream.h:275</div></div>
  579. <div class="ttc" id="classgrpc_1_1_server_async_reader_html"><div class="ttname"><a href="classgrpc_1_1_server_async_reader.html">grpc::ServerAsyncReader</a></div><div class="ttdef"><b>Definition:</b> async_stream.h:296</div></div>
  580. <div class="ttc" id="classgrpc_1_1_call_op_recv_initial_metadata_html"><div class="ttname"><a href="classgrpc_1_1_call_op_recv_initial_metadata.html">grpc::CallOpRecvInitialMetadata</a></div><div class="ttdef"><b>Definition:</b> call.h:401</div></div>
  581. <div class="ttc" id="classgrpc_1_1_client_async_reader_writer_html_af45cfa2b9cb0a27b673c0c793540db4a"><div class="ttname"><a href="classgrpc_1_1_client_async_reader_writer.html#af45cfa2b9cb0a27b673c0c793540db4a">grpc::ClientAsyncReaderWriter::WritesDone</a></div><div class="ttdeci">void WritesDone(void *tag) GRPC_OVERRIDE</div><div class="ttdoc">Signal the client is done with the writes. </div><div class="ttdef"><b>Definition:</b> async_stream.h:269</div></div>
  582. <div class="ttc" id="classgrpc_1_1_client_async_reader_html_aa14e3bc04d9852009f8b3094ce0d3ed4"><div class="ttname"><a href="classgrpc_1_1_client_async_reader.html#aa14e3bc04d9852009f8b3094ce0d3ed4">grpc::ClientAsyncReader::ClientAsyncReader</a></div><div class="ttdeci">ClientAsyncReader(ChannelInterface *channel, CompletionQueue *cq, const RpcMethod &amp;method, ClientContext *context, const W &amp;request, void *tag)</div><div class="ttdoc">Create a stream and write the first request out. </div><div class="ttdef"><b>Definition:</b> async_stream.h:105</div></div>
  583. <div class="ttc" id="classgrpc_1_1_async_reader_interface_html_aa644cf63c12ae8c9d5fda16a361f8a11"><div class="ttname"><a href="classgrpc_1_1_async_reader_interface.html#aa644cf63c12ae8c9d5fda16a361f8a11">grpc::AsyncReaderInterface::Read</a></div><div class="ttdeci">virtual void Read(R *msg, void *tag)=0</div><div class="ttdoc">Read a message of type R into msg. </div></div>
  584. <div class="ttc" id="classgrpc_1_1_call_op_generic_recv_message_html"><div class="ttname"><a href="classgrpc_1_1_call_op_generic_recv_message.html">grpc::CallOpGenericRecvMessage</a></div><div class="ttdef"><b>Definition:</b> call.h:294</div></div>
  585. <div class="ttc" id="classgrpc_1_1_server_async_reader_html_a7f351e1d526b250336402ee03b8cc75e"><div class="ttname"><a href="classgrpc_1_1_server_async_reader.html#a7f351e1d526b250336402ee03b8cc75e">grpc::ServerAsyncReader::ServerAsyncReader</a></div><div class="ttdeci">ServerAsyncReader(ServerContext *ctx)</div><div class="ttdef"><b>Definition:</b> async_stream.h:299</div></div>
  586. <div class="ttc" id="classgrpc_1_1_async_reader_interface_html"><div class="ttname"><a href="classgrpc_1_1_async_reader_interface.html">grpc::AsyncReaderInterface</a></div><div class="ttdoc">An interface that yields a sequence of messages of type R. </div><div class="ttdef"><b>Definition:</b> async_stream.h:67</div></div>
  587. <div class="ttc" id="classgrpc_1_1_client_async_reader_html_a0e5b71e2620dc95fe41305eef7ee7863"><div class="ttname"><a href="classgrpc_1_1_client_async_reader.html#a0e5b71e2620dc95fe41305eef7ee7863">grpc::ClientAsyncReader::ReadInitialMetadata</a></div><div class="ttdeci">void ReadInitialMetadata(void *tag) GRPC_OVERRIDE</div><div class="ttdoc">Request notification of the reading of the initial metadata. </div><div class="ttdef"><b>Definition:</b> async_stream.h:117</div></div>
  588. <div class="ttc" id="classgrpc_1_1_client_async_writer_interface_html"><div class="ttname"><a href="classgrpc_1_1_client_async_writer_interface.html">grpc::ClientAsyncWriterInterface</a></div><div class="ttdoc">Common interface for client side asynchronous writing. </div><div class="ttdef"><b>Definition:</b> async_stream.h:155</div></div>
  589. </div><!-- fragment --></div><!-- contents -->
  590. <!-- start footer part -->
  591. <hr class="footer"/><address class="footer"><small>
  592. Generated on Tue Mar 8 2016 15:59:03 for GRPC C++ by &#160;<a href="http://www.doxygen.org/index.html">
  593. <img class="footer" src="doxygen.png" alt="doxygen"/>
  594. </a> 1.8.6
  595. </small></address>
  596. </body>
  597. </html>