Java SingleResultCallback类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中com.mongodb.async.SingleResultCallback类的典型用法代码示例。如果您正苦于以下问题：Java SingleResultCallback类的具体用法？Java SingleResultCallback怎么用？Java SingleResultCallback使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

SingleResultCallback类属于com.mongodb.async包，在下文中一共展示了SingleResultCallback类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: getLatestOplogTimestamp

import com.mongodb.async.SingleResultCallback; //导入依赖的package包/类
/**
 * Returns the timestamp of the latest oplog entry.
 *
 * @param collection The oplog {@link MongoCollection}
 * @return The latest timestamp or {@code null} if no entry is available
 */
public static BsonTimestamp getLatestOplogTimestamp(MongoCollection<BsonDocument> collection) {
    final AtomicReference<BsonTimestamp> timestamp = new AtomicReference<>();
    final AtomicReference<Throwable> error = new AtomicReference<>();
    final CountDownLatch waiter = new CountDownLatch(1);
    collection.find().sort(new Document("$natural", -1)).limit(1).first(new SingleResultCallback<BsonDocument>() {
        @Override
        public void onResult(BsonDocument document, Throwable throwable) {
            if (throwable != null)
                error.set(throwable);
            if (document != null)
                timestamp.set(document.getTimestamp("ts"));
            waiter.countDown();
        }
    });
    ConcurrentUtils.safeAwait(waiter);
    Throwable realError = error.get();
    if (realError != null)
        throw Throwables.propagate(realError);
    return timestamp.get();
}

开发者ID:maxikg，项目名称:mongowg，代码行数:27，代码来源:OpLogUtils.java

示例2: getWithinBoundingBox

import com.mongodb.async.SingleResultCallback; //导入依赖的package包/类
public List<JSONObject> getWithinBoundingBox(double btm, double tp, double rght, double lft) {
    List<JSONObject> finalList = Collections.synchronizedList(new ArrayList<>());

    MongoCollection<Document> roadsNodes = this.database.getCollection("ollie_roads");

    Block<Document> getBlock = new Block<Document>() {
        @Override
        public void apply(final Document document) {
            finalList.add(new JSONObject(document));
        }
    };


    SingleResultCallback<Void> callbackWhenFinished = new SingleResultCallback<Void>() {
        @Override
        public void onResult(final Void result, final Throwable t) {
            latch.countDown();
        }
    };

    roadsNodes.find(and(gte("startNode.latitude", btm), lte("startNode.latitude", tp), gte("startNode.longitude", lft), lte("startNode.longitude", rght),
            gte("endNode.latitude", btm), lte("endNode.latitude", tp), gte("endNode.longitude", lft), lte("endNode.longitude", rght))).
            forEach(getBlock, callbackWhenFinished);

    try {
        latch.await();
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    return finalList;
}

开发者ID:OliMac1，项目名称:durafficpark，代码行数:32，代码来源:BoundingBoxNodes.java

示例3: convertCallback

import com.mongodb.async.SingleResultCallback; //导入依赖的package包/类
/**
 *
 * @param resultHandler
 * @param converter
 * @param <T>
 * @param <R>
 * @return
 */
private <T, R> SingleResultCallback<T> convertCallback(Handler<AsyncResult<R>> resultHandler, Function<T, R> converter) {
    Context context = mongi.vertx.getOrCreateContext();
    return (result, error) -> {
        context.runOnContext(v -> {
            if (error != null) {
                resultHandler.handle(Future.failedFuture(error));
            } else {
                resultHandler.handle(Future.succeededFuture(converter.apply(result)));
            }
        });
    };
}

开发者ID:stump201，项目名称:mongiORM，代码行数:21，代码来源:QueryAsync.java

示例4: createView

import com.mongodb.async.SingleResultCallback; //导入依赖的package包/类
@Override
public Publisher<Success> createView(final String viewName, final String viewOn, final List<? extends Bson> pipeline,
                                     final CreateViewOptions createViewOptions) {
    return new ObservableToPublisher<Success>(observe(new Block<SingleResultCallback<Success>>() {
        @Override
        public void apply(final SingleResultCallback<Success> callback) {
            wrapped.createView(viewName, viewOn, pipeline, createViewOptions, voidToSuccessCallback(callback));
        }
    }));
}

开发者ID:mongodb，项目名称:mongo-java-driver-reactivestreams，代码行数:11，代码来源:MongoDatabaseImpl.java

示例5: close

import com.mongodb.async.SingleResultCallback; //导入依赖的package包/类
@Override
public Observable<Success> close() {
    return RxObservables.create(Observables.observe(new Block<SingleResultCallback<Success>>() {
        @Override
        public void apply(final SingleResultCallback<Success> callback) {
            wrapped.close(voidToSuccessCallback(callback));
        }
    }), observableAdapter);
}

开发者ID:mongodb，项目名称:mongo-java-driver-rx，代码行数:10，代码来源:GridFSUploadStreamImpl.java

示例6: abort

import com.mongodb.async.SingleResultCallback; //导入依赖的package包/类
@Override
public Observable<Success> abort() {
    return RxObservables.create(Observables.observe(new Block<SingleResultCallback<Success>>() {
        @Override
        public void apply(final SingleResultCallback<Success> callback) {
            wrapped.abort(voidToSuccessCallback(callback));
        }
    }), observableAdapter);
}

开发者ID:mongodb，项目名称:mongo-java-driver-rx，代码行数:10，代码来源:GridFSUploadStreamImpl.java

示例7: delete

import com.mongodb.async.SingleResultCallback; //导入依赖的package包/类
@Override
public Publisher<Success> delete(final ClientSession clientSession, final BsonValue id) {
    return new ObservableToPublisher<Success>(observe(new Block<SingleResultCallback<Success>>() {
        @Override
        public void apply(final SingleResultCallback<Success> callback) {
            wrapped.delete(clientSession, id, voidToSuccessCallback(callback));
        }
    }));
}

开发者ID:mongodb，项目名称:mongo-java-driver-reactivestreams，代码行数:10，代码来源:GridFSBucketImpl.java

示例8: bulkWrite

import com.mongodb.async.SingleResultCallback; //导入依赖的package包/类
@Override
public Observable<BulkWriteResult> bulkWrite(final List<? extends WriteModel<? extends TDocument>> requests,
                                            final BulkWriteOptions options) {
    return RxObservables.create(Observables.observe(new Block<SingleResultCallback<BulkWriteResult>>() {
        @Override
        public void apply(final SingleResultCallback<BulkWriteResult> callback) {
            wrapped.bulkWrite(requests, options, callback);
        }
    }), observableAdapter);
}

开发者ID:mongodb，项目名称:mongo-java-driver-rx，代码行数:11，代码来源:MongoCollectionImpl.java