class Protobuf::Rpc::Connectors::Zmq

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