ione-rpc-test

gistfile1.rb

require 'ione/rpc'
require 'benchmark'
require 'msgpack'

CODEC = Ione::Rpc::StandardCodec.new(MessagePack)

class TranslateServer < Ione::Rpc::Server
  def initialize(port)
    super(port, CODEC)
  end

  def handle_request(request, _)
    Ione::Future.resolved("Server got: #{request}")
  end
end

server = TranslateServer.new(45678)
server_thread = Thread.new { server.start.value }

client = Ione::Rpc::Client.new(CODEC, hosts: ['localhost:45678']).start.value

puts Benchmark.measure {
  100_000.times { puts client.send_request("Hello server").value }
}

server.stop.value
server_thread.join