Sha256: 72bca9d92eff77c8cfbdc069652e77018bd8eb623e136335802b9a9711cef568
Contents?: true
Size: 622 Bytes
Versions: 6
Compression:
Stored size: 622 Bytes
Contents
# frozen_string_literal: true require 'grpc_kit/interceptors' module GrpcKit module Interceptors::Server class ServerStreamer < Streaming # @param interceptor [GrpcKit::GRPC::ServerInterceptor] # @param call [GrpcKit::Calls::Client::ServerStreamer] def invoke(interceptor, call) # We don't need a `:request` parameter but, # it shuoldn't remove from paramters due to having a compatibility of grpc gem. interceptor.server_streamer(request: nil, call: call, method: call.method) do |new_call = nil| yield(new_call || call) end end end end end
Version data entries
6 entries across 6 versions & 1 rubygems