connect-ruby

require "connect"
require_relative "ping_pb"

module Ping
  module V1
    module PingService
      class Client < ::Connect::Client
        self.service = "ping.v1.PingService"

        rpc :Ping, PingRequest, PingResponse
        rpc :PingStream, PingRequest, stream(PingResponse)
      end
    end
  end
end

client = Ping::V1::PingService::Client.new(
  transport: Connect::Transport.new(base_url: "http://localhost:8080")
)

response = client.ping(
  PingRequest.new(message: "Hello, world!")
)

puts response.message # => "Hello, world!"

response = client.ping_stream(
  PingRequest.new(message: "Hello, world!")
)

response.each do |message|
  puts message # => "Hello, world!"
end