Class FutureDirectives
- java.lang.Object
-
- Direct Known Subclasses:
HeaderDirectives
public abstract class FutureDirectives extends FormFieldDirectives
-
-
Constructor Summary
Constructors Constructor Description FutureDirectives()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description <T> RoutecompleteOrRecoverWith(java.util.function.Supplier<java.util.concurrent.CompletionStage<T>> f, Marshaller<T,RequestEntity> marshaller, java.util.function.Function<java.lang.Throwable,Route> inner)"Unwraps" aCompletionStageand runs the inner route when the stage has failed with the stage's failure exception as an extraction of typeThrowable.<T> RouteAdapteronComplete(java.util.concurrent.CompletionStage<T> cs, java.util.function.Function<scala.util.Try<T>,Route> inner)"Unwraps" aCompletionStageand runs the inner route after future completion with the future's value as an extraction of typeTry.<T> RouteAdapteronComplete(java.util.function.Supplier<java.util.concurrent.CompletionStage<T>> f, java.util.function.Function<scala.util.Try<T>,Route> inner)"Unwraps" aCompletionStageand runs the inner route after future completion with the future's value as an extraction of typeTry.<T> RouteAdapteronCompleteWithBreaker(akka.pattern.CircuitBreaker breaker, java.util.function.Supplier<java.util.concurrent.CompletionStage<T>> f, java.util.function.Function<scala.util.Try<T>,Route> inner)"Unwraps" aCompletionStage[T]and runs the inner route after future completion with the future's value as an extraction of typeTif the suppliedCircuitBreakeris closed.<T> RouteAdapteronSuccess(java.util.concurrent.CompletionStage<T> cs, java.util.function.Function<T,Route> inner)"Unwraps" aCompletionStageand runs the inner route after stage completion with the stage's value as an extraction of typeT.<T> RouteAdapteronSuccess(java.util.function.Supplier<java.util.concurrent.CompletionStage<T>> f, java.util.function.Function<T,Route> inner)"Unwraps" aCompletionStageand runs the inner route after stage completion with the stage's value as an extraction of typeT.-
Methods inherited from class akka.http.javadsl.server.directives.FormFieldDirectives
formField, formField, formFieldList, formFieldList, formFieldList, formFieldMap, formFieldMultiMap, formFieldOptional, formFieldOptional
-
Methods inherited from class akka.http.javadsl.server.directives.FileUploadDirectives
fileUpload, fileUploadAll, storeUploadedFile, storeUploadedFiles
-
Methods inherited from class akka.http.javadsl.server.directives.FileAndResourceDirectives
defaultContentTypeResolver, defaultDirectoryRenderer, getFromBrowseableDirectories, getFromBrowseableDirectories, getFromBrowseableDirectories, getFromBrowseableDirectories, getFromBrowseableDirectories, getFromBrowseableDirectory, getFromBrowseableDirectory, getFromBrowseableDirectory, getFromBrowseableDirectory, getFromDirectory, getFromDirectory, getFromFile, getFromFile, getFromFile, getFromFile, getFromFile, getFromResource, getFromResource, getFromResource, getFromResource, getFromResourceDirectory, getFromResourceDirectory, getFromResourceDirectory, getFromResourceDirectory, listDirectoryContents, listDirectoryContents, listDirectoryContents, listDirectoryContents
-
Methods inherited from class akka.http.javadsl.server.directives.ExecutionDirectives
handleExceptions, handleRejections
-
Methods inherited from class akka.http.javadsl.server.directives.DebuggingDirectives
logRequest, logRequest, logRequest, logRequestResult, logRequestResultOptional, logResult, logResult, logResult
-
Methods inherited from class akka.http.javadsl.server.directives.CookieDirectives
cookie, deleteCookie, deleteCookie, deleteCookie, deleteCookie, deleteCookie, optionalCookie, setCookie, setCookie
-
Methods inherited from class akka.http.javadsl.server.directives.CodingDirectives
decodeRequest, decodeRequestWith, decodeRequestWith, encodeResponse, encodeResponseWith, requestEncodedWith, responseEncodingAccepted, withPrecompressedMediaTypeSupport
-
Methods inherited from class akka.http.javadsl.server.directives.CacheConditionDirectives
conditional, conditional, conditional, conditional
-
Methods inherited from class akka.http.javadsl.server.directives.BasicDirectives
cancelRejection, cancelRejections, cancelRejections, extract, extractActorSystem, extractDataBytes, extractEntity, extractExecutionContext, extractLog, extractMatchedPath, extractMaterializer, extractParserSettings, extractRequest, extractRequestContext, extractRequestEntity, extractSettings, extractStrictEntity, extractStrictEntity, extractUnmatchedPath, extractUri, mapInnerRoute, mapRejections, mapRequest, mapRequestContext, mapResponse, mapResponseEntity, mapResponseHeaders, mapRouteResult, mapRouteResultFuture, mapRouteResultPF, mapRouteResultWith, mapRouteResultWithPF, mapSettings, mapUnmatchedPath, pass, provide, recoverRejections, recoverRejectionsWith, toStrictEntity, toStrictEntity, withExecutionContext, withLog, withMaterializer, withSettings
-
-
-
-
Method Detail
-
completeOrRecoverWith
public <T> Route completeOrRecoverWith(java.util.function.Supplier<java.util.concurrent.CompletionStage<T>> f, Marshaller<T,RequestEntity> marshaller, java.util.function.Function<java.lang.Throwable,Route> inner)
"Unwraps" aCompletionStageand runs the inner route when the stage has failed with the stage's failure exception as an extraction of typeThrowable. If the completion stage succeeds the request is completed using the values marshaller (This directive therefore requires a marshaller for the completion stage value type to be provided.)- Parameters:
f- (undocumented)marshaller- (undocumented)inner- (undocumented)- Returns:
- (undocumented)
-
onComplete
public <T> RouteAdapter onComplete(java.util.function.Supplier<java.util.concurrent.CompletionStage<T>> f, java.util.function.Function<scala.util.Try<T>,Route> inner)
"Unwraps" aCompletionStageand runs the inner route after future completion with the future's value as an extraction of typeTry.- Parameters:
f- (undocumented)inner- (undocumented)- Returns:
- (undocumented)
-
onComplete
public <T> RouteAdapter onComplete(java.util.concurrent.CompletionStage<T> cs, java.util.function.Function<scala.util.Try<T>,Route> inner)
"Unwraps" aCompletionStageand runs the inner route after future completion with the future's value as an extraction of typeTry.- Parameters:
cs- (undocumented)inner- (undocumented)- Returns:
- (undocumented)
-
onCompleteWithBreaker
public <T> RouteAdapter onCompleteWithBreaker(akka.pattern.CircuitBreaker breaker, java.util.function.Supplier<java.util.concurrent.CompletionStage<T>> f, java.util.function.Function<scala.util.Try<T>,Route> inner)
"Unwraps" aCompletionStage[T]and runs the inner route after future completion with the future's value as an extraction of typeTif the suppliedCircuitBreakeris closed.If the supplied
CircuitBreakeris open the request is rejected with aCircuitBreakerOpenRejection.- Parameters:
breaker- (undocumented)f- (undocumented)inner- (undocumented)- Returns:
- (undocumented)
-
onSuccess
public <T> RouteAdapter onSuccess(java.util.function.Supplier<java.util.concurrent.CompletionStage<T>> f, java.util.function.Function<T,Route> inner)
"Unwraps" aCompletionStageand runs the inner route after stage completion with the stage's value as an extraction of typeT. If the stage fails its failure Throwable is bubbled up to the nearest ExceptionHandler.- Parameters:
f- (undocumented)inner- (undocumented)- Returns:
- (undocumented)
-
onSuccess
public <T> RouteAdapter onSuccess(java.util.concurrent.CompletionStage<T> cs, java.util.function.Function<T,Route> inner)
"Unwraps" aCompletionStageand runs the inner route after stage completion with the stage's value as an extraction of typeT. If the stage fails its failure Throwable is bubbled up to the nearest ExceptionHandler.- Parameters:
cs- (undocumented)inner- (undocumented)- Returns:
- (undocumented)
-
-