Modifier and Type | Method and Description |
---|---|
JobRow |
JobRowBuilder.buildJobRow(javax.ws.rs.core.UriInfo request,
javax.ws.rs.container.ContainerRequestContext requestContext)
Builds the bean holding the metadata about an asynchronous job.
|
JobRow |
DefaultJobRowBuilder.buildJobRow(javax.ws.rs.core.UriInfo request,
javax.ws.rs.container.ContainerRequestContext requestContext)
Builds a JobRow with values for every field defined in
DefaultJobField . |
JobRow |
JobRow.withFieldValue(JobField field,
String value)
Returns a copy of this JobRow with the specified field set to the specified value.
|
Modifier and Type | Method and Description |
---|---|
Map<String,String> |
JobPayloadBuilder.buildPayload(JobRow jobRow,
javax.ws.rs.core.UriInfo uriInfo)
Given a Map containing job metadata, return a map representing job payload to be sent to the user.
|
Map<String,String> |
DefaultJobPayloadBuilder.buildPayload(JobRow jobRow,
javax.ws.rs.core.UriInfo uriInfo) |
Modifier and Type | Method and Description |
---|---|
JobRow |
ApiJobStoreException.getJobRow() |
Modifier and Type | Method and Description |
---|---|
rx.Observable<JobRow> |
HashJobStore.get(String id) |
rx.Observable<JobRow> |
NoOpApiJobStore.get(String id) |
rx.Observable<JobRow> |
ApiJobStore.get(String id)
Returns a cold Observable that emits 0 or 1 messages: the desired JobRow, or nothing if there is no JobRow with
the specified id.
|
rx.Observable<JobRow> |
HashJobStore.getAllRows() |
rx.Observable<JobRow> |
NoOpApiJobStore.getAllRows() |
rx.Observable<JobRow> |
ApiJobStore.getAllRows()
A cold observable that emits a stream of JobRows until all JobRows have been retrieved from the store.
|
rx.Observable<JobRow> |
HashJobStore.getFilteredRows(Set<JobRowFilter> jobRowFilters) |
rx.Observable<JobRow> |
NoOpApiJobStore.getFilteredRows(Set<JobRowFilter> jobRowFilter)
This method ignores the filters and returns an empty Observable.
|
rx.Observable<JobRow> |
ApiJobStore.getFilteredRows(Set<JobRowFilter> jobRowFilters)
This method takes a Set of JobRowFilters, ANDS them by default, and returns a cold observable that emits a
stream of JobRows which satisfy the given filter.
|
rx.Observable<JobRow> |
HashJobStore.save(JobRow metadata) |
rx.Observable<JobRow> |
NoOpApiJobStore.save(JobRow metadata) |
rx.Observable<JobRow> |
ApiJobStore.save(JobRow metadata)
Returns a cold Observable that emits the JobRow that has been stored.
|
Modifier and Type | Method and Description |
---|---|
rx.Observable<JobRow> |
HashJobStore.save(JobRow metadata) |
rx.Observable<JobRow> |
NoOpApiJobStore.save(JobRow metadata) |
rx.Observable<JobRow> |
ApiJobStore.save(JobRow metadata)
Returns a cold Observable that emits the JobRow that has been stored.
|
Constructor and Description |
---|
ApiJobStoreException(Exception cause,
JobRow jobRow)
Build an ApiJobStoreException with the cause and the JobRow on which the exception is thrown.
|
ApiJobStoreException(JobRow jobRow)
build an ApiJobStoreException associated with the given JobRow.
|
Constructor and Description |
---|
HashJobStore(Map<String,JobRow> store)
Builds a job store using the passed in map as the backing store.
|
Modifier and Type | Method and Description |
---|---|
rx.Observable<JobRow> |
AsynchronousWorkflows.getJobMarkedCompleteNotifications()
Returns an Observable that emits notifications that the JobRow has been updated.
|
Modifier and Type | Method and Description |
---|---|
AsynchronousWorkflows |
AsynchronousWorkflowsBuilder.buildAsynchronousWorkflows(rx.Observable<PreResponse> preResponseEmitter,
rx.Observable<Either<PreResponse,JobRow>> payloadEmitter,
JobRow jobMetadata,
Function<JobRow,String> jobMetadataSerializer)
Builds the asynchronous workflows.
|
AsynchronousWorkflows |
DefaultAsynchronousWorkflowsBuilder.buildAsynchronousWorkflows(rx.Observable<PreResponse> preResponseEmitter,
rx.Observable<Either<PreResponse,JobRow>> payloadEmitter,
JobRow jobMetadata,
Function<JobRow,String> jobMetadataSerializer) |
Modifier and Type | Method and Description |
---|---|
AsynchronousWorkflows |
AsynchronousWorkflowsBuilder.buildAsynchronousWorkflows(rx.Observable<PreResponse> preResponseEmitter,
rx.Observable<Either<PreResponse,JobRow>> payloadEmitter,
JobRow jobMetadata,
Function<JobRow,String> jobMetadataSerializer)
Builds the asynchronous workflows.
|
AsynchronousWorkflows |
AsynchronousWorkflowsBuilder.buildAsynchronousWorkflows(rx.Observable<PreResponse> preResponseEmitter,
rx.Observable<Either<PreResponse,JobRow>> payloadEmitter,
JobRow jobMetadata,
Function<JobRow,String> jobMetadataSerializer)
Builds the asynchronous workflows.
|
AsynchronousWorkflows |
DefaultAsynchronousWorkflowsBuilder.buildAsynchronousWorkflows(rx.Observable<PreResponse> preResponseEmitter,
rx.Observable<Either<PreResponse,JobRow>> payloadEmitter,
JobRow jobMetadata,
Function<JobRow,String> jobMetadataSerializer) |
AsynchronousWorkflows |
DefaultAsynchronousWorkflowsBuilder.buildAsynchronousWorkflows(rx.Observable<PreResponse> preResponseEmitter,
rx.Observable<Either<PreResponse,JobRow>> payloadEmitter,
JobRow jobMetadata,
Function<JobRow,String> jobMetadataSerializer) |
Constructor and Description |
---|
AsynchronousWorkflows(rx.Observable<PreResponse> queryResultsPayload,
rx.Observable<String> jobMetadataPayload,
rx.Observable<String> preResponseReadyNotifications,
rx.Observable<JobRow> jobMarkedCompleteNotifications)
Builds a bean containing all the message flows that support asynchronous processing.
|
Copyright © 2016–2018 Yahoo! Inc.. All rights reserved.