Lines Matching refs:receiver
14 #include <lib/async/receiver.h>
243 static void CallHandler(async_dispatcher_t* dispatcher, async_receiver_t* receiver,
245 static_cast<TestReceiver*>(receiver)->Handle(dispatcher, status, data);
286 async_exception_t* receiver,
289 static_cast<TestException*>(receiver)->Handle(dispatcher, status, report);
778 TestReceiver receiver;
779 EXPECT_EQ(ZX_ERR_BAD_STATE, receiver.QueuePacket(loop.dispatcher(), nullptr), "queue after shutdown");
780 EXPECT_EQ(0u, receiver.run_count, "run count 1");
956 // This receiver's handler will run concurrently on multiple threads
979 // This receiver's handler will run concurrently on multiple threads
1148 ThreadAssertReceiver receiver(&measure);
1150 EXPECT_EQ(ZX_OK, receiver.QueuePacket(loop.dispatcher(), nullptr), "queue packet");
1158 EXPECT_EQ(num_items, receiver.run_count, "run count");
1159 EXPECT_EQ(ZX_OK, receiver.last_status, "status");
1179 // The exception receiver object must survive the lifetime of the async
1181 ThreadAssertException receiver(zx_process_self(), 0, &measure);
1186 EXPECT_EQ(ZX_OK, receiver.Bind(loop.dispatcher()));
1210 // When |loop| goes out of scope |receiver| will get ZX_ERR_CANCELED,
1214 EXPECT_EQ(num_items, receiver.run_count);
1215 EXPECT_EQ(ZX_OK, receiver.last_status);
1219 EXPECT_EQ(ZX_ERR_CANCELED, receiver.last_status);