Class: Takagi::UdpClient

Inherits:
ClientBase show all
Defined in:
lib/takagi/client.rb

Overview

UDP-specific client implementation (internal) Users should use Takagi::Client with protocol: :udp instead

Instance Attribute Summary

Attributes inherited from ClientBase

#callbacks, #server_uri, #timeout

Instance Method Summary collapse

Methods inherited from ClientBase

#close, #closed?, #delete, #get, #get_json, #observe, #on, open, #post, #post_json, #put, #put_json

Constructor Details

#initialize(server_uri, timeout: 5, use_retransmission: true) ⇒ UdpClient

Initializes the UDP client

Parameters:

  • server_uri (String) —

    URL of the Takagi server

  • timeout (Integer) (defaults to: 5) —

    Maximum time to wait for a response

  • use_retransmission (Boolean) (defaults to: true) —

    Enable RFC 7252 ยง4.2 compliant retransmission (default: true)



141
142
143
144
145
146
147
148
149
 
# File 'lib/takagi/client.rb', line 141

def initialize(server_uri, timeout: 5, use_retransmission: true)
  super(server_uri, timeout: timeout)
  @use_retransmission = use_retransmission

  return unless @use_retransmission

  @retransmission_manager = Takagi::Message::RetransmissionManager.new
  @retransmission_manager.start
end