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