diff --git a/lntest/itest/lnd_channel_policy_test.go b/lntest/itest/lnd_channel_policy_test.go
index 236f0e73b..faac28c39 100644
--- a/lntest/itest/lnd_channel_policy_test.go
+++ b/lntest/itest/lnd_channel_policy_test.go
@@ -199,7 +199,7 @@ func testUpdateChannelPolicy(ht *lntemp.HarnessTest) {
 
 	// We expect this payment to fail, and that the min_htlc value is
 	// communicated back to us, since the attempted HTLC value was too low.
-	sendResp, err := alicePayStream.Recv()
+	sendResp, err := ht.ReceiveSendToRouteUpdate(alicePayStream)
 	require.NoError(ht, err, "unable to receive payment stream")
 
 	// Expected as part of the error message.
@@ -238,7 +238,7 @@ func testUpdateChannelPolicy(ht *lntemp.HarnessTest) {
 	err = alicePayStream.Send(sendReq)
 	require.NoError(ht, err, "unable to send payment")
 
-	sendResp, err = alicePayStream.Recv()
+	sendResp, err = ht.ReceiveSendToRouteUpdate(alicePayStream)
 	require.NoError(ht, err, "unable to receive payment stream")
 	require.Empty(ht, sendResp.PaymentError, "expected payment to succeed")
 
diff --git a/lntest/itest/lnd_routing_test.go b/lntest/itest/lnd_routing_test.go
index e425dbe44..b94e3b488 100644
--- a/lntest/itest/lnd_routing_test.go
+++ b/lntest/itest/lnd_routing_test.go
@@ -173,7 +173,7 @@ func testSingleHopSendToRouteCase(ht *lntemp.HarnessTest,
 			err := alicePayStream.Send(sendReq)
 			require.NoError(ht, err, "unable to send payment")
 
-			resp, err := alicePayStream.Recv()
+			resp, err := ht.ReceiveSendToRouteUpdate(alicePayStream)
 			require.NoError(ht, err, "unable to receive stream")
 			require.Emptyf(ht, resp.PaymentError,
 				"received payment error from %s: %v",