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