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> 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" aCompletionStage
and runs the inner route when the stage has failed with the stage's failure exception as an extraction of typeThrowable
.<T> RouteAdapter
onComplete(java.util.concurrent.CompletionStage<T> cs, java.util.function.Function<scala.util.Try<T>,Route> inner)
"Unwraps" aCompletionStage
and runs the inner route after future completion with the future's value as an extraction of typeTry
.<T> RouteAdapter
onComplete(java.util.function.Supplier<java.util.concurrent.CompletionStage<T>> f, java.util.function.Function<scala.util.Try<T>,Route> inner)
"Unwraps" aCompletionStage
and runs the inner route after future completion with the future's value as an extraction of typeTry
.<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 typeT
if the suppliedCircuitBreaker
is closed.<T> RouteAdapter
onSuccess(java.util.concurrent.CompletionStage<T> cs, java.util.function.Function<T,Route> inner)
"Unwraps" aCompletionStage
and runs the inner route after stage completion with the stage's value as an extraction of typeT
.<T> RouteAdapter
onSuccess(java.util.function.Supplier<java.util.concurrent.CompletionStage<T>> f, java.util.function.Function<T,Route> inner)
"Unwraps" aCompletionStage
and 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" aCompletionStage
and 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" aCompletionStage
and 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" aCompletionStage
and 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 typeT
if the suppliedCircuitBreaker
is closed.If the supplied
CircuitBreaker
is 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" aCompletionStage
and 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" aCompletionStage
and 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)
-
-