diff options
author | 2014-12-15 17:51:16 -0800 | |
---|---|---|
committer | 2014-12-16 17:05:37 -0800 | |
commit | 58327912922f922a376d2d2fe7db72d607bdd989 (patch) | |
tree | 5b4d63361640100008dc43496af823bc5d51ac96 /src/ruby/spec/client_server_spec.rb | |
parent | d8fd853cba184ecf398134c746858ad38bd32cb3 (diff) |
Adds support for trailing metadata
- removes the status class, replacing it with a Struct
- adds support for trailing metadata, merging into the call's initial metadata
- tracks []
Change on 2014/12/15 by temiola <temiola@google.com>
-------------
Created by MOE: http://code.google.com/p/moe-java
MOE_MIGRATED_REVID=82193372
Diffstat (limited to 'src/ruby/spec/client_server_spec.rb')
-rw-r--r-- | src/ruby/spec/client_server_spec.rb | 9 |
1 files changed, 4 insertions, 5 deletions
diff --git a/src/ruby/spec/client_server_spec.rb b/src/ruby/spec/client_server_spec.rb index 91abfc0313..5e68f524d6 100644 --- a/src/ruby/spec/client_server_spec.rb +++ b/src/ruby/spec/client_server_spec.rb @@ -154,8 +154,8 @@ shared_examples 'basic GRPC message delivery is OK' do server_call = ev.call server_call.server_accept(@server_queue, @server_finished_tag) server_call.server_end_initial_metadata() - sts = Status.new(StatusCodes::NOT_FOUND, 'not found') - server_call.start_write_status(sts, @server_tag) + server_call.start_write_status(StatusCodes::NOT_FOUND, 'not found', + @server_tag) # client gets an empty response for the read, preceeded by some metadata. call.start_read(@tag) @@ -175,8 +175,7 @@ shared_examples 'basic GRPC message delivery is OK' do call = new_client_call client_sends(call) server_call = server_receives_and_responds_with('server_response') - sts = Status.new(10101, 'status code is 10101') - server_call.start_write_status(sts, @server_tag) + server_call.start_write_status(10101, 'status code is 10101', @server_tag) # first the client says writes are done call.start_read(@tag) @@ -187,7 +186,7 @@ shared_examples 'basic GRPC message delivery is OK' do # but nothing happens until the server sends a status expect_next_event_on(@server_queue, FINISH_ACCEPTED, @server_tag) ev = expect_next_event_on(@server_queue, FINISHED, @server_finished_tag) - expect(ev.result).to be_a(Status) + expect(ev.result).to be_a(Struct::Status) # client gets FINISHED expect_next_event_on(@client_queue, FINISH_ACCEPTED, @tag) |