Sha256: f791b2a68cc755b15cfd618786ab80eacac792155c62cff7b7f8aca5a8ededf5
Contents?: true
Size: 638 Bytes
Versions: 8
Compression:
Stored size: 638 Bytes
Contents
# frozen_string_literal: true
module Nonnative
class GRPCServer < Nonnative::Server
def initialize(service)
@server = GRPC::RpcServer.new
server.handle(svc)
super service
end
protected
def perform_start
server.add_http2_port("0.0.0.0:#{proxy.port}", :this_port_is_insecure)
server.run
end
def perform_stop
server.stop
end
def wait_start
timeout.perform do
super until server.running?
end
end
def wait_stop
timeout.perform do
super until server.stopped?
end
end
private
attr_reader :server
end
end
Version data entries
8 entries across 8 versions & 1 rubygems