class Protobuf::Rpc::Connectors::Zmq

def snd_timeout

def snd_timeout
  @snd_timeout ||= begin
    case
    when options[:timeout] then
      options[:timeout]
    when ENV.key?("PB_ZMQ_CLIENT_SND_TIMEOUT") then
      ENV["PB_ZMQ_CLIENT_SND_TIMEOUT"].to_i
    else
      300_000 # 300 seconds
    end
  end
end