cancellable ruby server streamer.rb

module EzConfig
  class CallInterceptor < GRPC::ClientInterceptor
    def cancel!
      @call.instance_variable_get("@wrapped").instance_variable_get("@call").cancel
    end

    def server_streamer(request:, call:, method:, metadata:, &block)
      @call = call
      yield
    end
  end
end