Sha256: d07634d90f5459d5be7b5d0add570ff448f7ae6116580f7ee2c06fbb272915a9
Contents?: true
Size: 725 Bytes
Versions: 14
Compression:
Stored size: 725 Bytes
Contents
# frozen_string_literal: true require 'grpc_kit/interceptors' module GrpcKit module Interceptors::Client class ClientStreamer < Streaming private # @param interceptor [GrpcKit::Grpc::ClientInterceptor] # @param call [GrpcKit::Calls::Client::ClientStreamer] # @param metadata [Hash<String,String>] def invoke(interceptor, call, metadata) # We don't need a `:requests` parameter but, # it shuoldn't remove from paramters due to having a compatibility of grpc gem. interceptor.client_streamer(requests: nil, call: call, method: call.method, metadata: metadata) do |new_call = nil| yield(new_call || call, metadata) end end end end end
Version data entries
14 entries across 14 versions & 1 rubygems