@@ -96,7 +96,7 @@ discard block |
||
96 | 96 | /** |
97 | 97 | * Get commit callback. |
98 | 98 | * |
99 | - * @return callable|null |
|
99 | + * @return callable |
|
100 | 100 | */ |
101 | 101 | public function getCommitCallbacks() |
102 | 102 | { |
@@ -106,7 +106,7 @@ discard block |
||
106 | 106 | /** |
107 | 107 | * Get rollback callback. |
108 | 108 | * |
109 | - * @return callable|null |
|
109 | + * @return callable |
|
110 | 110 | */ |
111 | 111 | public function getRollbackCallbacks() |
112 | 112 | { |
@@ -116,7 +116,7 @@ discard block |
||
116 | 116 | /** |
117 | 117 | * Get buffer callback. |
118 | 118 | * |
119 | - * @return callable|null |
|
119 | + * @return callable |
|
120 | 120 | */ |
121 | 121 | public function getBufferCallbacks() |
122 | 122 | { |
@@ -54,10 +54,10 @@ |
||
54 | 54 | { |
55 | 55 | $this->index[$key][$operation->idx($this->connection)] = $operation; |
56 | 56 | $indexer = $this; |
57 | - $operation->onCommit(function ($operation) use ($key, $indexer) { |
|
57 | + $operation->onCommit(function($operation) use ($key, $indexer) { |
|
58 | 58 | $indexer->deIndex($key, $operation); |
59 | 59 | }); |
60 | - $operation->onRollback(function ($operation) use ($key, $indexer) { |
|
60 | + $operation->onRollback(function($operation) use ($key, $indexer) { |
|
61 | 61 | $indexer->deIndex($key, $operation); |
62 | 62 | }); |
63 | 63 | return $operation; |