diff options
author | 2015-04-15 08:09:25 -0700 | |
---|---|---|
committer | 2015-04-15 17:29:56 -0700 | |
commit | 1b39916bbaaef36662ce97dd9d7996e8ef6092a8 (patch) | |
tree | 07b8c3c77d6ce25f47b76e7fadd922f644baa17b /src/ruby/spec | |
parent | 72d70fc0af2c30609ef765ec938cc231d9dfe255 (diff) |
Adds an explicit Cancellation exception
- uses Forwardable to provide access the @call within an ActiveCall
- removes redundant methods from ActiveCall
Diffstat (limited to 'src/ruby/spec')
-rw-r--r-- | src/ruby/spec/generic/rpc_server_spec.rb | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/ruby/spec/generic/rpc_server_spec.rb b/src/ruby/spec/generic/rpc_server_spec.rb index 25ad6f7e59..1323bacfa6 100644 --- a/src/ruby/spec/generic/rpc_server_spec.rb +++ b/src/ruby/spec/generic/rpc_server_spec.rb @@ -396,11 +396,11 @@ describe GRPC::RpcServer do req = EchoMsg.new stub = SlowStub.new(@host, **@client_opts) op = stub.an_rpc(req, k1: 'v1', k2: 'v2', return_op: true) - cancel_thread = Thread.new do + Thread.new do # cancel the call sleep 0.1 op.cancel end - expect{op.execute}.to raise_error GRPC::Cancelled + expect { op.execute }.to raise_error GRPC::Cancelled @srv.stop t.join end |