File tree 1 file changed +3
-2
lines changed
src/test/kotlin/tech/relaycorp/relaynet/cogrpc/client
1 file changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -184,6 +184,7 @@ internal class CogRPCClientTest {
184
184
mockServerService.collectCargoReturned = ackRecorder
185
185
186
186
// Server sends cargo when client makes call and ends the call when ACK is received
187
+ var ackReceivedByServer: CargoDeliveryAck ? = null
187
188
val deliveryRequest = buildDeliveryRequest()
188
189
client.collectCargo { buildMessageSerialized() }
189
190
.onStart {
@@ -195,14 +196,14 @@ internal class CogRPCClientTest {
195
196
}
196
197
.collect {
197
198
launch(Dispatchers .IO ) {
198
- waitFor { ackRecorder.values.any () }
199
+ ackReceivedByServer = waitForNotNull { ackRecorder.values.firstOrNull () }
199
200
mockServerService.endCollectionCall()
200
201
}
201
202
}
202
203
203
204
assertEquals(
204
205
deliveryRequest.localId,
205
- ackRecorder.values.first() .id
206
+ ackReceivedByServer? .id
206
207
)
207
208
208
209
client.close()
You can’t perform that action at this time.
0 commit comments