Sha256: e6219ddfcf846256b8e9a4e0638214b7613c1c97cc3556dff7ae3cea1fe6539c
Contents?: true
Size: 468 Bytes
Versions: 14
Compression:
Stored size: 468 Bytes
Contents
# frozen_string_literal: true
require 'grpc_kit/interceptors'
module GrpcKit
module Interceptors::Server
class ClientStreamer < Streaming
# @param interceptor [GrpcKit::Grpc::ServerInterceptor]
# @param call [GrpcKit::Calls::Client::ClientStreamer]
def invoke(interceptor, call)
interceptor.client_streamer(call: call, method: call.method) do |new_call = nil|
yield(new_call || call)
end
end
end
end
end
Version data entries
14 entries across 14 versions & 1 rubygems