Lines Matching refs:promise
68 std::promise<void>* Send(TA* value) { in Send()
69 std::promise<void>* promise = new std::promise<void>(); in Send() local
74 common::Unretained(promise))); in Send()
75 return promise; in Send()
78 std::promise<TB*>* Receive() { in Receive()
79 std::promise<TB*>* promise = new std::promise<TB*>(); in Receive() local
81 …&TestBidiQueueEnd<TA, TB>::handle_receive, common::Unretained(this), common::Unretained(promise))); in Receive()
83 return promise; in Receive()
86 void handle_send(TA* value, std::promise<void>* promise) { in handle_send() argument
93 common::Unretained(promise))); in handle_send()
96 std::unique_ptr<TA> handle_register_enqueue(TA* value, std::promise<void>* promise) { in handle_register_enqueue() argument
98 promise->set_value(); in handle_register_enqueue()
102 void handle_receive(std::promise<TB*>* promise) { in handle_receive() argument
106 …QueueEnd<TA, TB>::handle_register_dequeue, common::Unretained(this), common::Unretained(promise))); in handle_receive()
109 void handle_register_dequeue(std::promise<TB*>* promise) { in handle_register_dequeue() argument
111 promise->set_value(end_->TryDequeue().get()); in handle_register_dequeue()