Sha256: 04e64fa9bbf8aee9065739e6c1b3e2ef7ab13b6100c9f0802c9a771efc2f9bfe
Contents?: true
Size: 723 Bytes
Versions: 14
Compression:
Stored size: 723 Bytes
Contents
# frozen_string_literal: true
require 'grpc_kit/interceptors'
module GrpcKit
module Interceptors::Client
class ServerStreamer < Streaming
private
# @param interceptor [GrpcKit::Grpc::ClientInterceptor]
# @param call [GrpcKit::Calls::Client::ServerStreamer]
# @param metadata [Hash<String,String>]
def invoke(interceptor, call, metadata)
# 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, 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