Contents

module Couchbase
  module Async
    class Callback
      include Java::NetSpyMemcachedInternal::OperationCompletionListener

      def initialize(operation, &callback)
        @operation, @callback = operation, callback
      end

      def onComplete(future)
        result = Couchbase::Result.new(operation: @operation, future: future)
        @callback.call(result)
      rescue Exception => e
        result.error = e
        return result
      end
    end
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
couchbase-jruby-client-0.1.7-java	lib/couchbase/async/callback.rb
couchbase-jruby-client-0.1.6-java	lib/couchbase/async/callback.rb
couchbase-jruby-client-0.1.5-java	lib/couchbase/async/callback.rb
couchbase-jruby-client-0.1.4	lib/couchbase/async/callback.rb
couchbase-jruby-client-0.1.3	lib/couchbase/async/callback.rb
couchbase-jruby-client-0.1.2	lib/couchbase/async/callback.rb
couchbase-jruby-client-0.1.1	lib/couchbase/async/callback.rb
couchbase-jruby-client-0.1.0-java	lib/couchbase/async/callback.rb