Searched refs:try_complete_eos (Results 1 – 2 of 2) sorted by relevance
431 fn try_complete_eos( in try_complete_eos() method
501 self.eos_manager.try_complete_eos(async_responses) in flush_response()1465 event_ret = match stream.eos_manager.try_complete_eos(vec![]) { in process_cmd()