Searched refs:server_stream_call (Results 1 – 2 of 2) sorted by relevance
29 def __init__(self, server_stream_call, logTag): argument30 if server_stream_call is None:32 self.server_stream_call = server_stream_call36 self.server_stream_call.cancel()39 return self.server_stream_call.cancelled()45 resp = self.server_stream_call.__next__()75 server_stream_call = continuation(client_call_details, request)77 return LoggingRandezvousWrapper(server_stream_call, retuningMsgLogTag)
72 def __init__(self, server_stream_call): argument73 if server_stream_call is None:76 self.server_stream_call = server_stream_call98 self.server_stream_call.cancel()150 for event in self.server_stream_call:158 if self.server_stream_call.cancelled():