lib/rom/sql/gateway.rb in rom-sql-3.2.0 vs lib/rom/sql/gateway.rb in rom-sql-3.3.0

@@ -79,10 +79,11 @@
       #
       # @api public
       def initialize(uri, options = EMPTY_HASH)
         @connection = connect(uri, options)
         load_extensions(Array(options[:extensions]))
+        Notifications.trigger("configuration.gateway.connected", connection: @connection)
 
         @options = options
 
         super
       end
@@ -245,6 +246,8 @@
       def transaction_runner(_)
         ROM::SQL::Transaction.new(connection)
       end
     end
   end
+
+  Configuration.register_event("configuration.gateway.connected")
 end