Add GenerateUntilCancel to handle concurrent sync + broadcast test case

tests/e2e/e2e.go

@@ -374,7 +374,9 @@ var _ = ginkgo.Describe("[HyperSDK APIs]", func() {
 				// Recover failure if exits
 				defer ginkgo.GinkgoRecover()
 
-				workload.GenerateNBlocks(ctx, require, network, txWorkloadFactory, 128)
+				txWorkload, err := txWorkloadFactory.NewSizedTxWorkload(uris[0], 128)
+				require.NoError(err)
+				workload.GenerateUntilCancel(ctx, require, network, txWorkload)
 			}()
 
 			// Give time for transactions to start processing

tests/workload/transactions.go

@@ -94,3 +94,28 @@ func GenerateNBlocks(ctx context.Context, require *require.Assertions, network N
 		require.NoError(err)
 	}, network.URIs())
 }
+
+func GenerateUntilCancel(
+	ctx context.Context,
+	require *require.Assertions,
+	network Network,
+	generator TxWorkloadIterator,
+) {
+	submitClient := rpc.NewJSONRPCClient(network.URIs()[0])
+
+	// Use backgroundCtx within the loop to avoid erroring due to an expected
+	// context cancellation.
+	backgroundCtx := context.Background()
+	for generator.Next() && ctx.Err() == nil {
+		tx, confirm, err := generator.GenerateTxWithAssertion(backgroundCtx)
+		require.NoError(err)
+
+		_, err = submitClient.SubmitTx(backgroundCtx, tx.Bytes())
+		require.NoError(err)
+
+		utils.ForEach(func(uri string) {
+			err := confirm(backgroundCtx, uri)
+			require.NoError(err)
+		}, network.URIs())
+	}
+}