Class: PulsarSdk::Client::Connection::SeqGenerator

Inherits:

Object

• Object
• PulsarSdk::Client::Connection::SeqGenerator

Defined in:

lib/pulsar_sdk/client/connection.rb

Instance Method Summary

• #initialize ⇒ SeqGenerator constructor

  A new instance of SeqGenerator.

• #next!(key) ⇒ Object

Constructor Details

#initialize ⇒ SeqGenerator

Returns a new instance of SeqGenerator.

# File 'lib/pulsar_sdk/client/connection.rb', line 341

def initialize
  @mutex = Mutex.new
  @seq = {}
end

Instance Method Details

#next!(key) ⇒ Object

# File 'lib/pulsar_sdk/client/connection.rb', line 356

def next!(key)
  @mutex.synchronize do
    @seq[key] ||= 0
    @seq[key] += 1
  end
end