utest/async/receiver_tests.cpp

5 #include <lib/async/cpp/receiver.h>
19     zx_status_t QueuePacket(async_receiver_t* receiver,
22         last_receiver = receiver;
44     void Handler(async_dispatcher_t* dispatcher, async::ReceiverBase* receiver,
47         last_receiver = receiver;
52     virtual async::ReceiverBase& receiver() = 0;
62     async::ReceiverBase& receiver() override { return receiver_; }
65     async::Receiver receiver_{[this](async_dispatcher_t* dispatcher, async::Receiver* receiver,
67         Handler(dispatcher, receiver, status, data);
73     async::ReceiverBase& receiver() override { return receiver_; }
83         async::Receiver receiver;
84         EXPECT_FALSE(receiver.has_handler());
86         receiver.set_handler([](async_dispatcher_t* dispatcher, async::Receiver* receiver,
88         EXPECT_TRUE(receiver.has_handler());
92         async::Receiver receiver([](async_dispatcher_t* dispatcher, async::Receiver* receiver,
94         EXPECT_TRUE(receiver.has_handler());
110     EXPECT_EQ(ZX_OK, harness.receiver().QueuePacket(&dispatcher, nullptr), "queue, null data");
117     EXPECT_EQ(ZX_ERR_BAD_STATE, harness.receiver().QueuePacket(&dispatcher, nullptr), "queue, null data");
124     EXPECT_EQ(ZX_OK, harness.receiver().QueuePacket(&dispatcher, &dummy_data), "queue, non-null data");
131     EXPECT_EQ(ZX_ERR_BAD_STATE, harness.receiver().QueuePacket(&dispatcher, &dummy_data), "queue, non-null data");
147     EXPECT_EQ(ZX_OK, harness.receiver().QueuePacket(&dispatcher, nullptr));
148     EXPECT_EQ(ZX_OK, harness.receiver().QueuePacket(&dispatcher, &dummy_data));
153     EXPECT_EQ(&harness.receiver(), harness.last_receiver);
160     EXPECT_EQ(&harness.receiver(), harness.last_receiver);
171     async_receiver_t receiver{};
172     EXPECT_EQ(ZX_ERR_NOT_SUPPORTED, async_queue_packet(&dispatcher, &receiver, nullptr), "valid args without data");
174     EXPECT_EQ(ZX_ERR_NOT_SUPPORTED, async_queue_packet(&dispatcher, &receiver, &data), "valid args with data");