Class: PgVersions::Connection

Inherits:
Object
  • Object
show all
Defined in:
lib/pg_versions/pg_versions.rb

Defined Under Namespace

Classes: Subscription

Instance Method Summary collapse

Constructor Details

#initialize(connection = nil) ⇒ Connection 



294
295
296
 
# File 'lib/pg_versions/pg_versions.rb', line 294

def initialize(connection=nil)
  @connection_thread = ConnectionThread.new(connection)
end

Instance Method Details

#bump(*channels) ⇒ Object 



302
303
304
 
# File 'lib/pg_versions/pg_versions.rb', line 302

def bump(*channels)
  @connection_thread.request(:bump, channels)
end

#close ⇒ Object 



298
299
300
 
# File 'lib/pg_versions/pg_versions.rb', line 298

def close()
  @connection_thread.request(:stop)
end

#read(*channels) ⇒ Object 



307
308
309
 
# File 'lib/pg_versions/pg_versions.rb', line 307

def read(*channels)
  @connection_thread.request(:read, channels)
end

#subscribe(*channels, known: {}, batch_delay: 0.01) ⇒ Object 



312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
 
# File 'lib/pg_versions/pg_versions.rb', line 312

def subscribe(*channels, known: {}, batch_delay: 0.01)
  subscription = Subscription.new(@connection_thread, batch_delay)
  subscription.subscribe([channels].flatten, known: known)
  if block_given?
    Thread.handle_interrupt(Object => :never) {
      begin
        Thread.handle_interrupt(Object => :immediate) {
          yield subscription
        }
      ensure
        subscription.drop
      end
    }
  else
    subscription
  end
end