From 535b71dce43c0ab2081a9cd960ed0c4a50d8cc33 Mon Sep 17 00:00:00 2001
From: Alexander Polcyn <apolcyn@google.com>
Date: Tue, 12 Jul 2016 15:52:08 -0700
Subject: [PATCH] changed compression request streaming enumerable to set write
flag on every message
---
src/ruby/pb/test/client.rb | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/src/ruby/pb/test/client.rb b/src/ruby/pb/test/client.rb
index 6d1e735d26..4c6d441dcb 100755
--- a/src/ruby/pb/test/client.rb
+++ b/src/ruby/pb/test/client.rb
@@ -244,8 +244,7 @@ class WriteFlagSettingStreamingInputEnumerable
def each
@requests_and_write_flags.each do |request_and_flag|
- @call_op.write_flag = request_and_flag[:write_flag] if
- request_and_flag[:write_flag]
+ @call_op.write_flag = request_and_flag[:write_flag]
yield request_and_flag[:request]
end
end
@@ -411,7 +410,8 @@ class NamedTests
# Create the requests messages and the corresponding write flags
# for each message
requests = WriteFlagSettingStreamingInputEnumerable.new([
- { request: first_request },
+ { request: first_request,
+ write_flag: 0 },
{ request: second_request,
write_flag: GRPC::Core::WriteFlags::NO_COMPRESS }
])
--
GitLab