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