| @@ -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; |