Searched refs:take_request (Results 1 – 7 of 7) sorted by relevance
91 first_request = rpc.take_request()92 second_request = rpc.take_request()93 third_request = rpc.take_request()114 first_request = rpc.take_request()117 second_request = rpc.take_request()144 requests[rpc] = [rpc.take_request()]149 requests[rpc].append(rpc.take_request())192 rpc.take_request()193 rpc.take_request()194 rpc.take_request()[all …]
60 def take_request(self): member in _StreamUnary61 return self._rpc_state.take_request()82 def take_request(self): member in _StreamStream83 return self._rpc_state.take_request()
130 def take_request(self): member in State
117 def take_request(self): member in StreamUnaryChannelRpc171 def take_request(self): member in StreamStreamChannelRpc
126 def take_request(self): member in ServerRpcHandler
25 read = self._handler.take_request()
75 def take_request(self): member in _Handler