下面列出了怎么用com.mongodb.reactivestreams.client.ListDatabasesPublisher的API类实例代码及写法,或者点击链接到github查看源代码。
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;
}
@Override
public Multi<Document> listDatabases(DatabaseListOptions options) {
if (options != null) {
ListDatabasesPublisher<Document> publisher = apply(options, client.listDatabases());
return Wrappers.toMulti(publisher);
} else {
return listDatabases();
}
}
@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);
}
}
private <T> ListDatabasesPublisher<T> apply(DatabaseListOptions options, ListDatabasesPublisher<T> publisher) {
if (options == null) {
return publisher;
}
return options.apply(publisher);
}
@Override
public Multi<Document> listDatabases(ClientSession clientSession, DatabaseListOptions options) {
ListDatabasesPublisher<Document> publisher = apply(options, client.listDatabases(clientSession));
return Wrappers.toMulti(publisher);
}
@Override
public ListDatabasesPublisher<Document> listDatabases() {
return mongoClient.listDatabases();
}
@Override
public <TResult> ListDatabasesPublisher<TResult> listDatabases(final Class<TResult> clazz) {
return mongoClient.listDatabases(clazz);
}
@Override
public ListDatabasesPublisher<Document> listDatabases(final ClientSession clientSession) {
return listDatabases(clientSession);
}
@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));
}