@@ -82,15 +82,15 @@ discard block |
||
82 | 82 | |
83 | 83 | $promise = new Promise(); |
84 | 84 | |
85 | - $this->on('error', function ($trans, $err) use ($promise) { |
|
85 | + $this->on('error', function($trans, $err) use ($promise) { |
|
86 | 86 | return $promise->reject($err); |
87 | 87 | }); |
88 | - $this->on('success', function ($trans) use ($promise) { |
|
88 | + $this->on('success', function($trans) use ($promise) { |
|
89 | 89 | return $promise->resolve(); |
90 | 90 | }); |
91 | 91 | |
92 | 92 | $this->open = false; |
93 | - $this->emit('commit', [ $this, $this->queue ]); |
|
93 | + $this->emit('commit', [$this, $this->queue]); |
|
94 | 94 | $this->queue = []; |
95 | 95 | |
96 | 96 | return $promise; |
@@ -108,7 +108,7 @@ discard block |
||
108 | 108 | } |
109 | 109 | |
110 | 110 | $this->open = false; |
111 | - $this->emit('rollback', [ $this ]); |
|
111 | + $this->emit('rollback', [$this]); |
|
112 | 112 | $this->queue = []; |
113 | 113 | |
114 | 114 | return Promise::doResolve(); |
@@ -18,42 +18,42 @@ discard block |
||
18 | 18 | /** |
19 | 19 | * @var int |
20 | 20 | */ |
21 | - const STATE_INIT = 0; |
|
21 | + const STATE_INIT = 0; |
|
22 | 22 | |
23 | 23 | /** |
24 | 24 | * @var int |
25 | 25 | */ |
26 | - const STATE_CONNECT_PENDING = 4; |
|
26 | + const STATE_CONNECT_PENDING = 4; |
|
27 | 27 | |
28 | 28 | /** |
29 | 29 | * @var int |
30 | 30 | */ |
31 | - const STATE_CONNECT_FAILED = 2; |
|
31 | + const STATE_CONNECT_FAILED = 2; |
|
32 | 32 | |
33 | 33 | /** |
34 | 34 | * @var int |
35 | 35 | */ |
36 | - const STATE_CONNECT_SUCCEEDED = 6; |
|
36 | + const STATE_CONNECT_SUCCEEDED = 6; |
|
37 | 37 | |
38 | 38 | /** |
39 | 39 | * @var int |
40 | 40 | */ |
41 | - const STATE_AUTH_PENDING = 5; |
|
41 | + const STATE_AUTH_PENDING = 5; |
|
42 | 42 | |
43 | 43 | /** |
44 | 44 | * @var int |
45 | 45 | */ |
46 | - const STATE_AUTH_FAILED = 3; |
|
46 | + const STATE_AUTH_FAILED = 3; |
|
47 | 47 | |
48 | 48 | /** |
49 | 49 | * @var int |
50 | 50 | */ |
51 | - const STATE_AUTH_SUCCEEDED = 7; |
|
51 | + const STATE_AUTH_SUCCEEDED = 7; |
|
52 | 52 | |
53 | 53 | /** |
54 | 54 | * @var int |
55 | 55 | */ |
56 | - const STATE_DISCONNECT_PENDING = 8; |
|
56 | + const STATE_DISCONNECT_PENDING = 8; |
|
57 | 57 | |
58 | 58 | /** |
59 | 59 | * @var int |
@@ -243,10 +243,10 @@ discard block |
||
243 | 243 | $trans->on('commit', function(TransactionInterface $trans, array $queue) { |
244 | 244 | $this->commitTransaction($queue)->then( |
245 | 245 | function() use($trans) { |
246 | - return $trans->emit('success', [ $trans ]); |
|
246 | + return $trans->emit('success', [$trans]); |
|
247 | 247 | }, |
248 | 248 | function($ex) use($trans) { |
249 | - return $trans->emit('error', [ $trans, $ex ]); |
|
249 | + return $trans->emit('error', [$trans, $ex]); |
|
250 | 250 | } |
251 | 251 | ); |
252 | 252 | $this->transBox->remove($trans); |