lib/prefab/cancellable_interceptor.rb in prefab-cloud-ruby-0.21.0 vs lib/prefab/cancellable_interceptor.rb in prefab-cloud-ruby-0.22.0
- old
+ new
@@ -11,19 +11,19 @@
def cancel
@call.instance_variable_get('@wrapped').instance_variable_get('@call').cancel
i = 0
while i < WAIT_SEC
if @call.instance_variable_get('@wrapped').cancelled?
- @base_client.log_internal Logger::DEBUG, 'Cancelled streaming.'
+ @base_client.log_internal ::Logger::DEBUG, 'Cancelled streaming.'
return
else
- @base_client.log_internal Logger::DEBUG, 'Unable to cancel streaming. Trying again'
+ @base_client.log_internal ::Logger::DEBUG, 'Unable to cancel streaming. Trying again'
@call.instance_variable_get('@wrapped').instance_variable_get('@call').cancel
i += 1
sleep(1)
end
end
- @base_client.log_internal Logger::INFO, 'Unable to cancel streaming.'
+ @base_client.log_internal ::Logger::INFO, 'Unable to cancel streaming.'
end
def request_response(request:, call:, method:, metadata:, &block)
shared(call, &block)
end