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