class PulsarSdk::Client::Connection::SeqGenerator

Public Class Methods

new() click to toggle source
# File lib/pulsar_sdk/client/connection.rb, line 341
def initialize
  @mutex = Mutex.new
  @seq = {}
end

Public Instance Methods

next!(key) click to toggle source
# File lib/pulsar_sdk/client/connection.rb, line 356
def next!(key)
  @mutex.synchronize do
    @seq[key] ||= 0
    @seq[key] += 1
  end
end