Method: ZooKeeper::RubyIO::AsyncOp#resume

Defined in:
lib/zkruby/rubyio.rb

#resume(error, response) ⇒ Object



260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
# File 'lib/zkruby/rubyio.rb', line 260

def resume(error,response)
    mutex.synchronize do
        @error = error
        @result = nil
        begin
            @result = @callback.call(response) unless error
        rescue StandardError => ex
            @error = ex
        end
       
        if @error && @errback
            begin
                @result = @errback.call(@error) 
                @error = nil
            rescue StandardError => ex
                @error = ex
            end
        end

        cv.signal()
    end
end