Sha256: 290d1e28b5a15e6d32bd6d311232b0af1d2a0c940e90dd5977b45f4fec528681
Contents?: true
Size: 861 Bytes
Versions: 15
Compression:
Stored size: 861 Bytes
Contents
# frozen_string_literal: true
require 'grpc_kit/rpcs'
require 'grpc_kit/calls/client_bidi_streamer'
module GrpcKit
module Rpcs::Client
class BidiStreamer < GrpcKit::Rpcs::ClientRpc
# @param stream [GrpcKit::Stream::ClientStream]
# @param _requests [Object] it's for compatibility, no use
# @param metadata [Hash<String, String>]
# @param timeout [GrpcKit::GrpcTime]
# @return [GrpcKit::Calls::Client::BidiStreamer]
def invoke(stream, _requests, metadata: {}, timeout: nil)
call = GrpcKit::Calls::Client::BidiStreamer.new(
metadata: metadata,
config: @config,
timeout: timeout,
stream: stream,
)
if @config.interceptor
@config.interceptor.intercept(call, metadata) { |c| c }
else
call
end
end
end
end
end
Version data entries
15 entries across 15 versions & 1 rubygems