42     // Send two messages.  in DECLARE_SKMESSAGEBUS_MESSAGE()
49     TArray<TestMessage> messages;  in DECLARE_SKMESSAGEBUS_MESSAGE()  local
50     inbox1.poll(&messages);  in DECLARE_SKMESSAGEBUS_MESSAGE()
51     REPORTER_ASSERT(r, 2 == messages.size());  in DECLARE_SKMESSAGEBUS_MESSAGE()
52     REPORTER_ASSERT(r, 5 == messages[0].x);  in DECLARE_SKMESSAGEBUS_MESSAGE()
53     REPORTER_ASSERT(r, 6 == messages[1].x);  in DECLARE_SKMESSAGEBUS_MESSAGE()
58     inbox1.poll(&messages);  in DECLARE_SKMESSAGEBUS_MESSAGE()
59     REPORTER_ASSERT(r, 1 == messages.size());  in DECLARE_SKMESSAGEBUS_MESSAGE()
60     REPORTER_ASSERT(r, 1 == messages[0].x);  in DECLARE_SKMESSAGEBUS_MESSAGE()
63     inbox1.poll(&messages);  in DECLARE_SKMESSAGEBUS_MESSAGE()
64     REPORTER_ASSERT(r, 0 == messages.size());  in DECLARE_SKMESSAGEBUS_MESSAGE()
66     // Over all this time, inbox2 should have piled up 3 messages.  in DECLARE_SKMESSAGEBUS_MESSAGE()
67     inbox2.poll(&messages);  in DECLARE_SKMESSAGEBUS_MESSAGE()
68     REPORTER_ASSERT(r, 3 == messages.size());  in DECLARE_SKMESSAGEBUS_MESSAGE()
69     REPORTER_ASSERT(r, 5 == messages[0].x);  in DECLARE_SKMESSAGEBUS_MESSAGE()
70     REPORTER_ASSERT(r, 6 == messages[1].x);  in DECLARE_SKMESSAGEBUS_MESSAGE()
71     REPORTER_ASSERT(r, 1 == messages[2].x);  in DECLARE_SKMESSAGEBUS_MESSAGE()
96     // Send two messages.  in DECLARE_SKMESSAGEBUS_MESSAGE()
103     TArray<sk_sp<TestMessageRefCnt>> messages;  in DECLARE_SKMESSAGEBUS_MESSAGE()  local
104     inbox1.poll(&messages);  in DECLARE_SKMESSAGEBUS_MESSAGE()
105     REPORTER_ASSERT(r, 2 == messages.size());  in DECLARE_SKMESSAGEBUS_MESSAGE()
106     REPORTER_ASSERT(r, messages[0]->unique());  in DECLARE_SKMESSAGEBUS_MESSAGE()
107     REPORTER_ASSERT(r, messages[1]->unique());  in DECLARE_SKMESSAGEBUS_MESSAGE()
108     REPORTER_ASSERT(r, 5 == messages[0]->x);  in DECLARE_SKMESSAGEBUS_MESSAGE()
109     REPORTER_ASSERT(r, 6 == messages[1]->x);  in DECLARE_SKMESSAGEBUS_MESSAGE()
114     inbox1.poll(&messages);  in DECLARE_SKMESSAGEBUS_MESSAGE()
115     REPORTER_ASSERT(r, 1 == messages.size());  in DECLARE_SKMESSAGEBUS_MESSAGE()
116     REPORTER_ASSERT(r, messages[0]->unique());  in DECLARE_SKMESSAGEBUS_MESSAGE()
117     REPORTER_ASSERT(r, 1 == messages[0]->x);  in DECLARE_SKMESSAGEBUS_MESSAGE()
124     inbox1.poll(&messages);  in DECLARE_SKMESSAGEBUS_MESSAGE()
125     REPORTER_ASSERT(r, 0 == messages.size());  in DECLARE_SKMESSAGEBUS_MESSAGE()
163     TArray<AddressedMessage> messages;  in DECLARE_SKMESSAGEBUS_MESSAGE()  local
164     inbox1.poll(&messages);  in DECLARE_SKMESSAGEBUS_MESSAGE()
165     REPORTER_ASSERT(r, messages.size() == 2);  in DECLARE_SKMESSAGEBUS_MESSAGE()
166     if (messages.size() == 2) {  in DECLARE_SKMESSAGEBUS_MESSAGE()
167         REPORTER_ASSERT(r, !messages[0].fInboxID.isValid());  in DECLARE_SKMESSAGEBUS_MESSAGE()
168         REPORTER_ASSERT(r, messages[1].fInboxID == id1);  in DECLARE_SKMESSAGEBUS_MESSAGE()
170     inbox2.poll(&messages);  in DECLARE_SKMESSAGEBUS_MESSAGE()
171     REPORTER_ASSERT(r, messages.size() == 2);  in DECLARE_SKMESSAGEBUS_MESSAGE()
172     if (messages.size() == 2) {  in DECLARE_SKMESSAGEBUS_MESSAGE()
173         REPORTER_ASSERT(r, !messages[0].fInboxID.isValid());  in DECLARE_SKMESSAGEBUS_MESSAGE()
174         REPORTER_ASSERT(r, messages[1].fInboxID == id2);  in DECLARE_SKMESSAGEBUS_MESSAGE()