A Test client that can be used in unit tests to verify requests and stub responses.
Example:
TestRxRestDatastoreClient client = new TestRxRestDatastoreClient(Person)
def mock = client.expect {
uriTemplate '/person/1'
}
.respond {
json {
id 1
name "Fred"
age 10
dateOfBirth "2006-07-09T00:00+0000"
}
}
Person p = Person.get(1).toBlocking().first()
mock.verify()
Fields inherited from class | Fields |
---|---|
class RxRestDatastoreClient |
allowBlockingOperations |
class org.grails.datastore.rx.AbstractRxDatastoreClient |
__$stMC, SETTING_ALLOW_BLOCKING, PREFIX, SETTING_AUTO_FLUSH, SETTING_FLUSH_MODE, SETTING_FAIL_ON_ERROR, SETTING_DEFAULT_MAPPING, SETTING_DEFAULT_CONSTRAINTS, SETTING_CUSTOM_TYPES, SETTING_MULTI_TENANCY_MODE, SETTING_MULTI_TENANT_RESOLVER_CLASS, SETTING_DATASOURCES, SETTING_DATASOURCE, SETTING_DB_CREATE |
Constructor and description |
---|
TestRxRestDatastoreClient
(org.springframework.core.env.PropertyResolver configuration, java.lang.Class... classes) |
TestRxRestDatastoreClient
(java.lang.Class... classes) |
TestRxRestDatastoreClient
(java.lang.Iterable<java.lang.String> connectionSourceNames, org.springframework.core.env.PropertyResolver configuration, java.lang.Class... classes) |
TestRxRestDatastoreClient
(java.lang.Iterable<java.lang.String> connectionSourceNames, java.lang.Class... classes) |
protected TestRxRestDatastoreClient
(org.grails.datastore.mapping.core.connections.ConnectionSources<io.reactivex.netty.client.ConnectionProviderFactory, RestConnectionSourceSettings> connectionSources, java.lang.Class... classes) |
protected TestRxRestDatastoreClient
(org.grails.datastore.mapping.core.connections.ConnectionSources<io.reactivex.netty.client.ConnectionProviderFactory, RestConnectionSourceSettings> connectionSources, RestClientMappingContext mappingContext) |
Type | Name and description |
---|---|
protected RxRestDatastoreClient |
createChildClient(org.grails.datastore.mapping.core.connections.SingletonConnectionSources<io.reactivex.netty.client.ConnectionProviderFactory, RestConnectionSourceSettings> singletonConnectionSources) |
TestHttpServerRequestBuilder |
expect(groovy.lang.Closure callable) Add expectations |
TestRxRestDatastoreClient |
getDatastoreClient(java.lang.String connectionSourceName) |
HttpTestServer |
getHttpTestServer() |
protected static org.grails.datastore.mapping.core.connections.ConnectionSources<io.reactivex.netty.client.ConnectionProviderFactory, RestConnectionSourceSettings> |
initializeConnectionSources(java.lang.Iterable<java.lang.String> connectionSourceNames, org.springframework.core.env.PropertyResolver configuration) |
void |
reset() Reset the state of the mock |
Methods inherited from class | Name |
---|---|
class RxRestDatastoreClient |
batchDelete, batchWrite, configureProxy, createChildClient, createContentWriteObservable, createDefaultConnectionSourcesForHosts, createEntityQuery, createEntityQuery, createHttpClient, createInstanceApi, createMappingContext, createQuery, createServerSocketAddresses, createStaticApi, doClose, expandUri, generateIdentifier, get, getMappingContext, getNativeInterface, initDefaultConverters, initialize, isAllowBlockingOperations, prepareRequest |
class org.grails.datastore.rx.AbstractRxDatastoreClient |
org.grails.datastore.rx.AbstractRxDatastoreClient#getMetaClass(), org.grails.datastore.rx.AbstractRxDatastoreClient#setMetaClass(groovy.lang.MetaClass), org.grails.datastore.rx.AbstractRxDatastoreClient#invokeMethod(java.lang.String, java.lang.Object), org.grails.datastore.rx.AbstractRxDatastoreClient#proxy(org.grails.datastore.mapping.query.Query, org.grails.datastore.rx.query.QueryState), org.grails.datastore.rx.AbstractRxDatastoreClient#proxy(org.grails.datastore.mapping.query.Query), org.grails.datastore.rx.AbstractRxDatastoreClient#proxy(java.lang.Class, java.io.Serializable), org.grails.datastore.rx.AbstractRxDatastoreClient#proxy(java.lang.Class, java.io.Serializable, org.grails.datastore.rx.query.QueryState), org.grails.datastore.rx.AbstractRxDatastoreClient#pfaccess$0(org.grails.datastore.rx.AbstractRxDatastoreClient), org.grails.datastore.rx.AbstractRxDatastoreClient#setMessageSource(org.springframework.context.MessageSource), org.grails.datastore.rx.AbstractRxDatastoreClient#getMappingContext(), org.grails.datastore.rx.AbstractRxDatastoreClient#getMultiTenancyMode(), org.grails.datastore.rx.AbstractRxDatastoreClient#getProxyFactory(), org.grails.datastore.rx.AbstractRxDatastoreClient#createEntityQuery(org.grails.datastore.mapping.model.PersistentEntity, org.grails.datastore.rx.query.QueryState, java.util.Map), org.grails.datastore.rx.AbstractRxDatastoreClient#createEntityQuery(org.grails.datastore.mapping.model.PersistentEntity, org.grails.datastore.rx.query.QueryState), org.grails.datastore.rx.AbstractRxDatastoreClient#batchDelete(org.grails.datastore.rx.batch.BatchOperation), org.grails.datastore.rx.AbstractRxDatastoreClient#processAssociations(org.grails.datastore.mapping.model.PersistentEntity, java.io.Serializable, java.lang.Object, org.grails.datastore.mapping.reflect.EntityReflector, org.grails.datastore.rx.batch.BatchOperation, java.util.List), org.grails.datastore.rx.AbstractRxDatastoreClient#generateIdentifier(org.grails.datastore.mapping.model.PersistentEntity, java.lang.Object, org.grails.datastore.mapping.reflect.EntityReflector), org.grails.datastore.rx.AbstractRxDatastoreClient#batchWrite(org.grails.datastore.rx.batch.BatchOperation), org.grails.datastore.rx.AbstractRxDatastoreClient#doClose(), org.grails.datastore.rx.AbstractRxDatastoreClient#createStaticApi(org.grails.datastore.mapping.model.PersistentEntity, java.lang.String), org.grails.datastore.rx.AbstractRxDatastoreClient#createStaticApi(org.grails.datastore.mapping.model.PersistentEntity), org.grails.datastore.rx.AbstractRxDatastoreClient#createInstanceApi(org.grails.datastore.mapping.model.PersistentEntity, java.lang.String), org.grails.datastore.rx.AbstractRxDatastoreClient#createInstanceApi(org.grails.datastore.mapping.model.PersistentEntity), org.grails.datastore.rx.AbstractRxDatastoreClient#createValidationApi(org.grails.datastore.mapping.model.PersistentEntity, java.lang.String), org.grails.datastore.rx.AbstractRxDatastoreClient#createValidationApi(org.grails.datastore.mapping.model.PersistentEntity), org.grails.datastore.rx.AbstractRxDatastoreClient#getDatastoreClients(), org.grails.datastore.rx.AbstractRxDatastoreClient#deleteAll(java.lang.Iterable, java.util.Map), org.grails.datastore.rx.AbstractRxDatastoreClient#deleteAll(java.lang.Iterable), org.grails.datastore.rx.AbstractRxDatastoreClient#persistAll(java.lang.Iterable, java.util.Map), org.grails.datastore.rx.AbstractRxDatastoreClient#persistAll(java.lang.Iterable), org.grails.datastore.rx.AbstractRxDatastoreClient#insertAll(java.lang.Iterable, java.util.Map), org.grails.datastore.rx.AbstractRxDatastoreClient#insertAll(java.lang.Iterable), org.grails.datastore.rx.AbstractRxDatastoreClient#createQuery(java.lang.Class, java.util.Map), org.grails.datastore.rx.AbstractRxDatastoreClient#createQuery(java.lang.Class, org.grails.datastore.rx.query.QueryState), org.grails.datastore.rx.AbstractRxDatastoreClient#createQuery(java.lang.Class), org.grails.datastore.rx.AbstractRxDatastoreClient#createQuery(java.lang.Class, org.grails.datastore.rx.query.QueryState, java.util.Map), org.grails.datastore.rx.AbstractRxDatastoreClient#getEventPublisher(), org.grails.datastore.rx.AbstractRxDatastoreClient#getConnectionSources(), org.grails.datastore.rx.AbstractRxDatastoreClient#getDatastoreClient(java.lang.String), org.grails.datastore.rx.AbstractRxDatastoreClient#getTenantResolver(), org.grails.datastore.rx.AbstractRxDatastoreClient#getDatastoreClientForTenantId(java.io.Serializable), org.grails.datastore.rx.AbstractRxDatastoreClient#isSchemaless(), org.grails.datastore.rx.AbstractRxDatastoreClient#setEventPublisher(org.grails.datastore.gorm.events.ConfigurableApplicationEventPublisher), org.grails.datastore.rx.AbstractRxDatastoreClient#persist(java.lang.Object, java.util.Map), org.grails.datastore.rx.AbstractRxDatastoreClient#persist(java.lang.Object), org.grails.datastore.rx.AbstractRxDatastoreClient#get(java.lang.Class, java.io.Serializable), org.grails.datastore.rx.AbstractRxDatastoreClient#get(java.lang.Class, java.io.Serializable, org.grails.datastore.rx.query.QueryState), org.grails.datastore.rx.AbstractRxDatastoreClient#setProperty(java.lang.String, java.lang.Object), org.grails.datastore.rx.AbstractRxDatastoreClient#getProperty(java.lang.String), org.grails.datastore.rx.AbstractRxDatastoreClient#delete(java.lang.Object, java.util.Map), org.grails.datastore.rx.AbstractRxDatastoreClient#delete(java.lang.Object), org.grails.datastore.rx.AbstractRxDatastoreClient#close(), org.grails.datastore.rx.AbstractRxDatastoreClient#insert(java.lang.Object, java.util.Map), org.grails.datastore.rx.AbstractRxDatastoreClient#wait(long, int), org.grails.datastore.rx.AbstractRxDatastoreClient#wait(long), org.grails.datastore.rx.AbstractRxDatastoreClient#wait(), org.grails.datastore.rx.AbstractRxDatastoreClient#equals(java.lang.Object), org.grails.datastore.rx.AbstractRxDatastoreClient#toString(), org.grails.datastore.rx.AbstractRxDatastoreClient#hashCode(), org.grails.datastore.rx.AbstractRxDatastoreClient#getClass(), org.grails.datastore.rx.AbstractRxDatastoreClient#notify(), org.grails.datastore.rx.AbstractRxDatastoreClient#notifyAll(), org.grails.datastore.rx.AbstractRxDatastoreClient#getNativeInterface(), org.grails.datastore.rx.AbstractRxDatastoreClient#isAllowBlockingOperations() |
Add expectations
callable
- The callableReset the state of the mock