类com.mongodb.reactivestreams.client.ListDatabasesPublisher源码实例Demo

下面列出了怎么用com.mongodb.reactivestreams.client.ListDatabasesPublisher的API类实例代码及写法,或者点击链接到github查看源代码。

源代码1 项目: quarkus   文件: DatabaseListOptions.java
public <T> ListDatabasesPublisher<T> apply(ListDatabasesPublisher<T> publisher) {
    ListDatabasesPublisher<T> result = publisher;
    if (nameOnly) {
        result = publisher.nameOnly(nameOnly);
    }
    if (filter != null) {
        result = publisher.filter(filter);
    }
    if (maxTime > 0) {
        result.maxTime(maxTime, maxTimeUnit);
    }
    return result;
}
 
源代码2 项目: quarkus   文件: ReactiveMongoClientImpl.java
@Override
public Multi<Document> listDatabases(DatabaseListOptions options) {
    if (options != null) {
        ListDatabasesPublisher<Document> publisher = apply(options, client.listDatabases());
        return Wrappers.toMulti(publisher);
    } else {
        return listDatabases();
    }
}
 
源代码3 项目: quarkus   文件: ReactiveMongoClientImpl.java
@Override
public <T> Multi<T> listDatabases(Class<T> clazz, DatabaseListOptions options) {
    if (options != null) {
        ListDatabasesPublisher<T> publisher = apply(options, client.listDatabases(clazz));
        return Wrappers.toMulti(publisher);
    } else {
        return listDatabases(clazz);
    }
}
 
源代码4 项目: quarkus   文件: ReactiveMongoClientImpl.java
private <T> ListDatabasesPublisher<T> apply(DatabaseListOptions options, ListDatabasesPublisher<T> publisher) {
    if (options == null) {
        return publisher;
    }
    return options.apply(publisher);
}
 
源代码5 项目: quarkus   文件: ReactiveMongoClientImpl.java
@Override
public Multi<Document> listDatabases(ClientSession clientSession, DatabaseListOptions options) {
    ListDatabasesPublisher<Document> publisher = apply(options, client.listDatabases(clientSession));
    return Wrappers.toMulti(publisher);
}
 
源代码6 项目: ditto   文件: MongoClientWrapper.java
@Override
public ListDatabasesPublisher<Document> listDatabases() {
    return mongoClient.listDatabases();
}
 
源代码7 项目: ditto   文件: MongoClientWrapper.java
@Override
public <TResult> ListDatabasesPublisher<TResult> listDatabases(final Class<TResult> clazz) {
    return mongoClient.listDatabases(clazz);
}
 
源代码8 项目: ditto   文件: MongoClientWrapper.java
@Override
public ListDatabasesPublisher<Document> listDatabases(final ClientSession clientSession) {
    return listDatabases(clientSession);
}
 
源代码9 项目: ditto   文件: MongoClientWrapper.java
@Override
public <TResult> ListDatabasesPublisher<TResult> listDatabases(final ClientSession clientSession,
        final Class<TResult> clazz) {

    return mongoClient.listDatabases(clientSession, clazz);
}
 
@Override
public ListDatabasesPublisher<Document> listDatabases() {
    return listDatabases(Document.class);
}
 
@Override
public <TResult> ListDatabasesPublisher<TResult> listDatabases(final Class<TResult> clazz) {
    return new ListDatabasesPublisherImpl<TResult>(wrapped.listDatabases(clazz));
}
 
@Override
public ListDatabasesPublisher<Document> listDatabases(final ClientSession clientSession) {
    return listDatabases(clientSession, Document.class);
}
 
@Override
public <TResult> ListDatabasesPublisher<TResult> listDatabases(final ClientSession clientSession, final Class<TResult> clazz) {
    return new ListDatabasesPublisherImpl<TResult>(wrapped.listDatabases(clientSession.getWrapped(), clazz));
}
 
 类所在包
 类方法
 同包方法