Sha256: 3dec46adccdddb91a2330c7c161503d0638fc421218d939719060e0c77c17027
Contents?: true
Size: 649 Bytes
Versions: 12
Compression:
Stored size: 649 Bytes
Contents
# frozen_string_literal: true require 'grpc_kit/call' require 'grpc_kit/calls' module GrpcKit module Calls::Client class ServerStreamer < GrpcKit::Call include Enumerable alias outgoing_metadata metadata # @param data [Object] request message # @return [void] def send_msg(data) @stream.send_msg(data, last: true, metadata: outgoing_metadata) end # @return [Object] response object def recv @stream.recv_msg end # @yieldparam response [Object] each response object of server streaming RPC def each loop { yield(recv) } end end end end
Version data entries
12 entries across 12 versions & 1 rubygems