12
12
*/
13
13
package org .web3j .protocol .scenarios ;
14
14
15
+ import java .math .BigDecimal ;
16
+ import java .math .BigInteger ;
17
+ import java .util .Iterator ;
18
+ import java .util .LinkedList ;
19
+ import java .util .List ;
20
+ import java .util .Map ;
21
+ import java .util .concurrent .ConcurrentHashMap ;
22
+ import java .util .concurrent .ConcurrentLinkedQueue ;
23
+ import java .util .concurrent .Future ;
24
+
15
25
import com .carrotsearch .junitbenchmarks .BenchmarkOptions ;
16
26
import org .junit .jupiter .api .BeforeAll ;
17
27
import org .junit .jupiter .api .Test ;
28
+
18
29
import org .web3j .EVMTest ;
19
30
import org .web3j .NodeType ;
20
31
import org .web3j .protocol .Web3j ;
27
38
import org .web3j .tx .response .QueuingTransactionReceiptProcessor ;
28
39
import org .web3j .utils .Convert ;
29
40
30
- import java .math .BigDecimal ;
31
- import java .math .BigInteger ;
32
- import java .util .Iterator ;
33
- import java .util .LinkedList ;
34
- import java .util .List ;
35
- import java .util .Map ;
36
- import java .util .concurrent .ConcurrentHashMap ;
37
- import java .util .concurrent .ConcurrentLinkedQueue ;
38
- import java .util .concurrent .Future ;
39
-
40
41
import static org .junit .jupiter .api .Assertions .*;
41
42
import static org .web3j .tx .TransactionManager .DEFAULT_POLLING_ATTEMPTS_PER_TX_HASH ;
42
43
@@ -74,11 +75,11 @@ public void testTransactionPolling() throws Exception {
74
75
}
75
76
76
77
for (int i = 0 ;
77
- i < DEFAULT_POLLING_ATTEMPTS_PER_TX_HASH && !transactionReceipts .isEmpty ();
78
- i ++) {
78
+ i < DEFAULT_POLLING_ATTEMPTS_PER_TX_HASH && !transactionReceipts .isEmpty ();
79
+ i ++) {
79
80
80
81
for (Iterator <Future <TransactionReceipt >> iterator = transactionReceipts .iterator ();
81
- iterator .hasNext (); ) {
82
+ iterator .hasNext (); ) {
82
83
Future <TransactionReceipt > transactionReceiptFuture = iterator .next ();
83
84
84
85
if (transactionReceiptFuture .isDone ()) {
@@ -140,8 +141,7 @@ public void accept(TransactionReceipt transactionReceipt) {
140
141
}
141
142
142
143
@ Override
143
- public void exception (Exception exception ) {
144
- }
144
+ public void exception (Exception exception ) {}
145
145
},
146
146
DEFAULT_POLLING_ATTEMPTS_PER_TX_HASH ,
147
147
POLLING_FREQUENCY ));
@@ -156,8 +156,8 @@ public void exception(Exception exception) {
156
156
}
157
157
158
158
for (int i = 0 ;
159
- i < DEFAULT_POLLING_ATTEMPTS_PER_TX_HASH && !pendingTransactions .isEmpty ();
160
- i ++) {
159
+ i < DEFAULT_POLLING_ATTEMPTS_PER_TX_HASH && !pendingTransactions .isEmpty ();
160
+ i ++) {
161
161
for (TransactionReceipt transactionReceipt : transactionReceipts ) {
162
162
assertFalse (transactionReceipt .getBlockHash ().isEmpty ());
163
163
pendingTransactions .remove (transactionReceipt .getTransactionHash ());
0 commit comments