transaction.md

    public function someMethod(DatabaseAdapter $adapter): Promise
    {
        return call(
            static function() use ($adapter): \Generator
            {
                /** @var \ServiceBus\Storage\Common\Transaction $transaction */
                $transaction = yield $adapter->transaction();
                
                try {

                    yield $transaction->execute('SELECT NOW()');
                    
                    yield $transaction->commit();
                }catch(\Throwable $throwable){
                    yield $transaction->rollback();
                }
            }
        );
    }