lib/grumlin/traversal_start.rb in grumlin-1.0.2 vs lib/grumlin/traversal_start.rb in grumlin-1.0.3.beta1

- old
+ new

@@ -7,10 +7,13 @@ class AlreadyBoundToTransactionError < TraversalError; end def tx raise AlreadyBoundToTransactionError if @session_id - transaction = tx_class.new(self.class, pool: @pool, middlewares: @middlewares) + # Pool should have size of 1 when working with session + pool = Async::Pool::Controller.new(Grumlin::Client::PoolResource, limit: 1) + + transaction = tx_class.new(self.class, pool: pool, middlewares: @middlewares) return transaction unless block_given? result = nil begin