Skip to content

Commit

Permalink
itest: rename func assertRecvNtfsEvent to assertAssetSendNtfsEvent
Browse files Browse the repository at this point in the history
This commit renames a helper function for clarity.
  • Loading branch information
ffranr committed Nov 1, 2023
1 parent 2fe7e62 commit c7e559b
Showing 1 changed file with 9 additions and 9 deletions.
18 changes: 9 additions & 9 deletions itest/send_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -68,7 +68,7 @@ func testBasicSendUnidirectional(t *harnessTest) {
timeout := 2 * defaultProofTransferReceiverAckTimeout
ctx, cancel := context.WithTimeout(ctxb, timeout)
defer cancel()
assertRecvNtfsEvent(
assertAssetSendNtfsEvent(
t, ctx, eventNtfns, targetEventSelector, numSends,
)
}()
Expand Down Expand Up @@ -463,7 +463,7 @@ func testReattemptFailedSendHashmailCourier(t *harnessTest) {
ctx, cancel := context.WithTimeout(ctxb, timeout)
defer cancel()

assertRecvNtfsEvent(
assertAssetSendNtfsEvent(
t, ctx, eventNtfns, targetEventSelector,
expectedEventCount,
)
Expand Down Expand Up @@ -570,7 +570,7 @@ func testReattemptFailedSendUniCourier(t *harnessTest) {
ctx, cancel := context.WithTimeout(ctxb, timeout)
defer cancel()

assertRecvNtfsEvent(
assertAssetSendNtfsEvent(
t, ctx, eventNtfns, targetEventSelector,
expectedEventCount,
)
Expand Down Expand Up @@ -802,7 +802,7 @@ func testOfflineReceiverEventuallyReceives(t *harnessTest) {
ctx, cancel := context.WithTimeout(ctxb, timeout)
defer cancel()

assertRecvNtfsEvent(
assertAssetSendNtfsEvent(
t, ctx, eventNtfns, targetEventSelector,
expectedEventCount,
)
Expand Down Expand Up @@ -851,10 +851,10 @@ func testOfflineReceiverEventuallyReceives(t *harnessTest) {
wg.Wait()
}

// assertRecvNtfsEvent asserts that the given event notification was received.
// This function will block until the event is received or the event stream is
// closed.
func assertRecvNtfsEvent(t *harnessTest, ctx context.Context,
// assertAssetSendNtfsEvent asserts that the given asset send event notification
// was received. This function will block until the event is received or the
// event stream is closed.
func assertAssetSendNtfsEvent(t *harnessTest, ctx context.Context,
eventNtfns taprpc.TaprootAssets_SubscribeSendAssetEventNtfnsClient,
targetEventSelector func(*taprpc.SendAssetEvent) bool,
expectedCount int) {
Expand Down Expand Up @@ -893,7 +893,7 @@ func assertRecvNtfsEvent(t *harnessTest, ctx context.Context,
require.Equal(t.t, expectedCount, countFound)
}

// assertRecvNtfsEvent asserts that the given asset receive event notification
// assertAssetSendNtfsEvent asserts that the given asset receive event notification
// was received. This function will block until the event is received or the
// event stream is closed.
func assertAssetRecvNtfsEvent(t *harnessTest, ctx context.Context,
Expand Down

0 comments on commit c7e559b

Please sign in to comment.