Class FramedEntityStreamingDirectives
java.lang.Object
akka.http.javadsl.server.directives.BasicDirectives
akka.http.javadsl.server.directives.CacheConditionDirectives
akka.http.javadsl.server.directives.CodingDirectives
akka.http.javadsl.server.directives.CookieDirectives
akka.http.javadsl.server.directives.DebuggingDirectives
akka.http.javadsl.server.directives.ExecutionDirectives
akka.http.javadsl.server.directives.FileAndResourceDirectives
akka.http.javadsl.server.directives.FileUploadDirectives
akka.http.javadsl.server.directives.FormFieldDirectives
akka.http.javadsl.server.directives.FutureDirectives
akka.http.javadsl.server.directives.HeaderDirectives
akka.http.javadsl.server.directives.AttributeDirectives
akka.http.javadsl.server.directives.HostDirectives
akka.http.javadsl.server.directives.MarshallingDirectives
akka.http.javadsl.server.directives.MethodDirectives
akka.http.javadsl.server.directives.MiscDirectives
akka.http.javadsl.server.directives.ParameterDirectives
akka.http.javadsl.server.directives.PathDirectives
akka.http.javadsl.server.directives.RangeDirectives
akka.http.javadsl.server.directives.RespondWithDirectives
akka.http.javadsl.server.directives.RouteDirectives
akka.http.javadsl.server.directives.SchemeDirectives
akka.http.javadsl.server.directives.SecurityDirectives
akka.http.javadsl.server.directives.WebSocketDirectives
akka.http.javadsl.server.directives.TimeoutDirectives
akka.http.javadsl.server.directives.FramedEntityStreamingDirectives
- Direct Known Subclasses:
AllDirectives
,FramedEntityStreamingDirectives$
EXPERIMENTAL API
-
Nested Class Summary
Nested classes/interfaces inherited from class akka.http.javadsl.server.directives.SecurityDirectives
SecurityDirectives.ProvidedCredentials, SecurityDirectives.ProvidedCredentials$
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic <T> RouteAdapter
attribute
(AttributeKey<T> key, Function<T, Route> inner) static <T> Route
authenticateBasic
(String realm, Function<Optional<SecurityDirectives.ProvidedCredentials>, Optional<T>> authenticator, Function<T, Route> inner) static <T> Route
authenticateBasicAsync
(String realm, Function<Optional<SecurityDirectives.ProvidedCredentials>, CompletionStage<Optional<T>>> authenticator, Function<T, Route> inner) static <T> Route
authenticateBasicAsyncOptional
(String realm, Function<Optional<SecurityDirectives.ProvidedCredentials>, CompletionStage<Optional<T>>> authenticator, Function<Optional<T>, Route> inner) static <T> Route
authenticateBasicOptional
(String realm, Function<Optional<SecurityDirectives.ProvidedCredentials>, Optional<T>> authenticator, Function<Optional<T>, Route> inner) static <T> Route
authenticateBasicPF
(String realm, scala.PartialFunction<Optional<SecurityDirectives.ProvidedCredentials>, T> authenticator, Function<T, Route> inner) static <T> Route
authenticateBasicPFAsync
(String realm, scala.PartialFunction<Optional<SecurityDirectives.ProvidedCredentials>, CompletionStage<T>> authenticator, Function<T, Route> inner) static <T> Route
authenticateOAuth2
(String realm, Function<Optional<SecurityDirectives.ProvidedCredentials>, Optional<T>> authenticator, Function<T, Route> inner) static <T> Route
authenticateOAuth2Async
(String realm, Function<Optional<SecurityDirectives.ProvidedCredentials>, CompletionStage<Optional<T>>> authenticator, Function<T, Route> inner) static <T> Route
authenticateOAuth2AsyncOptional
(String realm, Function<Optional<SecurityDirectives.ProvidedCredentials>, CompletionStage<Optional<T>>> authenticator, Function<Optional<T>, Route> inner) static <T> Route
authenticateOAuth2Optional
(String realm, Function<Optional<SecurityDirectives.ProvidedCredentials>, Optional<T>> authenticator, Function<Optional<T>, Route> inner) static <C extends HttpCredentials,
T>
RouteauthenticateOrRejectWithChallenge
(Class<C> c, Function<Optional<C>, CompletionStage<scala.util.Either<HttpChallenge, T>>> authenticator, Function<T, Route> inner) static <T> Route
authenticateOrRejectWithChallenge
(Function<Optional<HttpCredentials>, CompletionStage<scala.util.Either<HttpChallenge, T>>> authenticator, Function<T, Route> inner) static Route
static Route
authorizeAsync
(Supplier<CompletionStage<Object>> check, Supplier<Route> inner) static Route
authorizeAsyncWithRequestContext
(akka.japi.function.Function<RequestContext, CompletionStage<Object>> check, Supplier<Route> inner) static Route
authorizeWithRequestContext
(akka.japi.function.Function<RequestContext, Object> check, Supplier<Route> inner) static Route
cancelRejection
(Rejection rejection, Supplier<Route> inner) static Route
cancelRejections
(Iterable<Class<?>> classes, Supplier<Route> inner) static Route
cancelRejections
(Predicate<Rejection> filter, Supplier<Route> inner) static Route
checkSameOrigin
(HttpOriginRange allowed, Supplier<Route> inner) static Route
complete
(HttpResponse response) static RouteAdapter
complete
(RequestEntity entity) static RouteAdapter
complete
(ResponseEntity entity) static Route
complete
(StatusCode status) static RouteAdapter
complete
(StatusCode status, RequestEntity entity) static RouteAdapter
complete
(StatusCode status, ResponseEntity entity) static RouteAdapter
complete
(StatusCode status, Iterable<HttpHeader> headers, RequestEntity entity) static RouteAdapter
complete
(StatusCode status, Iterable<HttpHeader> headers, ResponseEntity entity) static <T> RouteAdapter
complete
(StatusCode status, Iterable<HttpHeader> headers, T value, Marshaller<T, RequestEntity> marshaller) static RouteAdapter
complete
(StatusCode status, String entity) static <T> RouteAdapter
complete
(StatusCode status, T value, Marshaller<T, RequestEntity> marshaller) static RouteAdapter
complete
(Iterable<HttpHeader> headers, RequestEntity entity) static RouteAdapter
complete
(Iterable<HttpHeader> headers, ResponseEntity entity) static <T> RouteAdapter
complete
(Iterable<HttpHeader> headers, T value, Marshaller<T, RequestEntity> marshaller) static Route
static <T> RouteAdapter
complete
(T value, Marshaller<T, HttpResponse> marshaller) static <T> RouteAdapter
completeOK
(T value, Marshaller<T, RequestEntity> marshaller) static RouteAdapter
static <T> RouteAdapter
completeOKWithFuture
(CompletionStage<T> value, Marshaller<T, RequestEntity> marshaller) static <T> RouteAdapter
completeOKWithFuture
(scala.concurrent.Future<T> value, Marshaller<T, RequestEntity> marshaller) static RouteAdapter
static RouteAdapter
completeOKWithFutureString
(scala.concurrent.Future<String> value) <T,
M> Route completeOKWithSource
(akka.stream.javadsl.Source<T, M> source, Marshaller<T, RequestEntity> m, EntityStreamingSupport support) static <T> Route
completeOrRecoverWith
(Supplier<CompletionStage<T>> f, Marshaller<T, RequestEntity> marshaller, Function<Throwable, Route> inner) static <T> Route
completeWith
(Marshaller<T, ? extends HttpResponse> marshaller, Consumer<Consumer<T>> inner) static RouteAdapter
static <T> RouteAdapter
completeWithFuture
(CompletionStage<T> value, Marshaller<T, HttpResponse> marshaller) static <T> RouteAdapter
completeWithFuture
(scala.concurrent.Future<T> value, Marshaller<T, HttpResponse> marshaller) static RouteAdapter
completeWithFutureResponse
(scala.concurrent.Future<HttpResponse> value) static Route
static Route
completeWithFutureStatus
(scala.concurrent.Future<StatusCode> status) <T,
M> Route completeWithSource
(akka.stream.javadsl.Source<T, M> source, Marshaller<T, akka.util.ByteString> m, EntityStreamingSupport support) static Route
static Route
static Route
conditional
(DateTime lastModified, Supplier<Route> inner) static Route
conditional
(EntityTag eTag, DateTime lastModified, Supplier<Route> inner) static Route
conditional
(EntityTag eTag, Supplier<Route> inner) static Route
static Route
cookie
(String name, Function<HttpCookiePair, Route> inner) static Route
decodeRequest
(Supplier<Route> inner) static Route
decodeRequestWith
(Coder coder, Supplier<Route> inner) static Route
decodeRequestWith
(Iterable<Coder> coders, Supplier<Route> inner) static ContentTypeResolver
static DirectoryRenderer
static Route
static Route
deleteCookie
(HttpCookie cookie, Supplier<Route> inner) static Route
deleteCookie
(Iterable<HttpCookie> cookies, Supplier<Route> inner) static Route
static Route
deleteCookie
(String name, String domain, Supplier<Route> inner) static Route
deleteCookie
(String name, Supplier<Route> inner) static Route
encodeResponse
(Supplier<Route> inner) static Route
encodeResponseWith
(Iterable<Coder> coders, Supplier<Route> inner) static <T> Route
entity
(Unmarshaller<? super HttpEntity, T> unmarshaller, Function<T, Route> inner) <T> Route
entityAsSourceOf
(Unmarshaller<akka.util.ByteString, T> um, EntityStreamingSupport support, Function<akka.stream.javadsl.Source<T, akka.NotUsed>, Route> inner) static <T> Route
extract
(Function<RequestContext, T> extract, Function<T, Route> inner) static Route
extractActorSystem
(Function<akka.actor.ActorSystem, Route> inner) static Route
extractClientIP
(Function<RemoteAddress, Route> inner) static Route
static RouteAdapter
extractDataBytes
(Function<akka.stream.javadsl.Source<akka.util.ByteString, Object>, Route> inner) static Route
extractEntity
(Function<RequestEntity, Route> inner) static Route
extractExecutionContext
(Function<scala.concurrent.ExecutionContextExecutor, Route> inner) static Route
extractHost
(Function<String, Route> inner) static Route
extractLog
(Function<akka.event.LoggingAdapter, Route> inner) static RouteAdapter
extractMatchedPath
(Function<String, Route> inner) static Route
extractMaterializer
(Function<akka.stream.Materializer, Route> inner) static RouteAdapter
extractMethod
(Function<HttpMethod, Route> inner) static Route
extractOfferedWsProtocols
(Function<List<String>, Route> inner) static RouteAdapter
static RouteAdapter
extractRequest
(Function<HttpRequest, Route> inner) static RouteAdapter
static Route
static RouteAdapter
extractRequestTimeout
(Function<scala.concurrent.duration.Duration, Route> inner) static Route
extractScheme
(Function<String, Route> inner) static RouteAdapter
extractSettings
(Function<RoutingSettings, Route> inner) static Route
extractStrictEntity
(scala.concurrent.duration.FiniteDuration timeout, long maxBytes, Function<HttpEntity.Strict, Route> inner) static Route
extractStrictEntity
(scala.concurrent.duration.FiniteDuration timeout, Function<HttpEntity.Strict, Route> inner) static RouteAdapter
extractUnmatchedPath
(Function<String, Route> inner) static Route
static RouteAdapter
extractUri
(Function<Uri, Route> inner) static Route
static Route
static Route
fileUpload
(String fieldName, BiFunction<FileInfo, akka.stream.javadsl.Source<akka.util.ByteString, Object>, Route> inner) static Route
fileUploadAll
(String fieldName, Function<List<Map.Entry<FileInfo, akka.stream.javadsl.Source<akka.util.ByteString, Object>>>, Route> inner) static <T> Route
static Route
static <T> Route
formFieldList
(Unmarshaller<String, T> t, String name, Function<List<T>, Route> inner) static Route
static Route
static Route
static Route
static <T> Route
formFieldOptional
(Unmarshaller<String, T> t, String name, Function<Optional<T>, Route> inner) static Route
static Route
static Route
getFromBrowseableDirectories
(Iterable<String> directories, ContentTypeResolver resolver) static Route
getFromBrowseableDirectories
(Iterable<String> directories, DirectoryRenderer renderer) static Route
getFromBrowseableDirectories
(Iterable<String> directories, DirectoryRenderer renderer, ContentTypeResolver resolver) static Route
getFromBrowseableDirectories
(String... directories) static Route
getFromBrowseableDirectories
(scala.collection.immutable.Seq<String> directories) static Route
getFromBrowseableDirectory
(String directory) static Route
getFromBrowseableDirectory
(String directory, ContentTypeResolver resolver) static Route
getFromBrowseableDirectory
(String directory, DirectoryRenderer renderer) static Route
getFromBrowseableDirectory
(String directory, DirectoryRenderer renderer, ContentTypeResolver resolver) static Route
getFromDirectory
(String directoryPath) static Route
getFromDirectory
(String directoryPath, ContentTypeResolver resolver) static Route
getFromFile
(File file) static Route
getFromFile
(File file, ContentType contentType) static Route
getFromFile
(File file, ContentTypeResolver resolver) static Route
getFromFile
(String file) static Route
getFromFile
(String file, ContentTypeResolver resolver) static Route
getFromResource
(String path) static Route
getFromResource
(String path, ContentType contentType) static Route
getFromResource
(String path, ContentType contentType, ClassLoader classLoader) static Route
getFromResource
(String path, ContentTypeResolver resolver) static Route
getFromResourceDirectory
(String directoryName) static Route
getFromResourceDirectory
(String directoryName, ContentTypeResolver resolver) static Route
getFromResourceDirectory
(String directoryName, ContentTypeResolver resolver, ClassLoader classLoader) static Route
getFromResourceDirectory
(String directoryName, ClassLoader classLoader) static Route
handle
(akka.japi.function.Function<HttpRequest, CompletionStage<HttpResponse>> handler) static RouteAdapter
handleExceptions
(ExceptionHandler handler, Supplier<Route> inner) static RouteAdapter
handleRejections
(RejectionHandler handler, Supplier<Route> inner) static Route
handleSync
(akka.japi.function.Function<HttpRequest, HttpResponse> handler) static <T> Route
handleWebSocketMessages
(akka.stream.javadsl.Flow<Message, Message, T> handler) static <T> Route
handleWebSocketMessagesForOptionalProtocol
(akka.stream.javadsl.Flow<Message, Message, T> handler, Optional<String> subprotocol) static <T> Route
handleWebSocketMessagesForProtocol
(akka.stream.javadsl.Flow<Message, Message, T> handler, String subprotocol) static <T,
R> Route handleWith
(Unmarshaller<? super HttpEntity, T> unmarshaller, Marshaller<R, ? extends HttpResponse> marshaller, Function<T, R> inner) static Route
static <T> RouteAdapter
headerValue
(Function<HttpHeader, Optional<T>> f, Function<T, Route> inner) static RouteAdapter
headerValueByName
(String headerName, Function<String, Route> inner) static <T extends HttpHeader>
RouteAdapterheaderValueByType
(Class<T> t, Function<T, Route> inner) static <T> RouteAdapter
headerValuePF
(scala.PartialFunction<HttpHeader, T> pf, Function<T, Route> inner) static Route
static Route
static Route
static Route
static Route
ignoreTrailingSlash
(Supplier<Route> inner) static Route
listDirectoryContents
(DirectoryRenderer directoryRenderer, String... directories) static Route
listDirectoryContents
(DirectoryRenderer directoryRenderer, scala.collection.immutable.Seq<String> directories) static Route
listDirectoryContents
(String... directories) static Route
listDirectoryContents
(scala.collection.immutable.Seq<String> directories) static Route
logRequest
(String marker, akka.event.Logging.LogLevel level, Supplier<Route> inner) static Route
logRequest
(String marker, Supplier<Route> inner) static Route
logRequest
(Function<HttpRequest, LogEntry> show, Supplier<Route> inner) static RouteAdapter
logRequestResult
(BiFunction<HttpRequest, HttpResponse, LogEntry> showSuccess, BiFunction<HttpRequest, List<Rejection>, LogEntry> showRejection, Supplier<Route> inner) static RouteAdapter
logRequestResultOptional
(BiFunction<HttpRequest, HttpResponse, Optional<LogEntry>> showSuccess, BiFunction<HttpRequest, List<Rejection>, Optional<LogEntry>> showRejection, Supplier<Route> inner) static Route
static Route
static RouteAdapter
logResult
(Function<HttpResponse, LogEntry> showSuccess, Function<List<Rejection>, LogEntry> showRejection, Supplier<Route> inner) static Route
static Route
static Route
mapRequest
(Function<HttpRequest, HttpRequest> f, Supplier<Route> inner) static Route
mapRequestContext
(Function<RequestContext, RequestContext> f, Supplier<Route> inner) static Route
mapResponse
(Function<HttpResponse, HttpResponse> f, Supplier<Route> inner) static Route
mapResponseEntity
(Function<ResponseEntity, ResponseEntity> f, Supplier<Route> inner) static Route
mapResponseHeaders
(Function<List<HttpHeader>, List<HttpHeader>> f, Supplier<Route> inner) static Route
mapRouteResult
(Function<RouteResult, RouteResult> f, Supplier<Route> inner) static Route
mapRouteResultFuture
(Function<CompletionStage<RouteResult>, CompletionStage<RouteResult>> f, Supplier<Route> inner) static Route
mapRouteResultPF
(scala.PartialFunction<RouteResult, RouteResult> f, Supplier<Route> inner) static Route
mapRouteResultWith
(Function<RouteResult, CompletionStage<RouteResult>> f, Supplier<Route> inner) static Route
mapRouteResultWithPF
(scala.PartialFunction<RouteResult, CompletionStage<RouteResult>> f, Supplier<Route> inner) static Route
mapSettings
(Function<RoutingSettings, RoutingSettings> f, Supplier<Route> inner) static Route
static Route
method
(HttpMethod method, Supplier<Route> inner) static <T> RouteAdapter
onComplete
(CompletionStage<T> cs, Function<scala.util.Try<T>, Route> inner) static <T> RouteAdapter
onComplete
(Supplier<CompletionStage<T>> f, Function<scala.util.Try<T>, Route> inner) static <T> RouteAdapter
onCompleteWithBreaker
(akka.pattern.CircuitBreaker breaker, Supplier<CompletionStage<T>> f, Function<scala.util.Try<T>, Route> inner) static <T> RouteAdapter
onSuccess
(CompletionStage<T> cs, Function<T, Route> inner) static <T> RouteAdapter
onSuccess
(Supplier<CompletionStage<T>> f, Function<T, Route> inner) static <T> RouteAdapter
optionalAttribute
(AttributeKey<T> key, Function<Optional<T>, Route> inner) static Route
optionalCookie
(String name, Function<Optional<HttpCookiePair>, Route> inner) static <T> RouteAdapter
optionalHeaderValue
(Function<HttpHeader, Optional<T>> f, Function<Optional<T>, Route> inner) static RouteAdapter
static <T extends HttpHeader>
RouteAdapteroptionalHeaderValueByType
(Class<T> t, Function<Optional<T>, Route> inner) static <T> RouteAdapter
optionalHeaderValuePF
(scala.PartialFunction<HttpHeader, T> pf, Function<Optional<T>, Route> inner) static Route
static Route
overrideMethodWithParameter
(String paramName, Supplier<Route> inner) static <T> Route
static Route
static <T> Route
parameterList
(Unmarshaller<String, T> t, String name, Function<List<T>, Route> inner) static Route
static Route
static Route
static Route
static <T> Route
parameterOptional
(Unmarshaller<String, T> t, String name, Function<Optional<T>, Route> inner) static Route
static <T> Route
parameterOrDefault
(Unmarshaller<String, T> t, T defaultValue, String name, Function<T, Route> inner) static <T> Route
parameterRequiredValue
(Unmarshaller<String, T> t, T requiredValue, String name, Supplier<Route> inner) static Route
static Route
static Route
path
(PathMatcher0 p, Supplier<Route> inner) static <T> Route
path
(PathMatcher1<T> p, Function<T, Route> inner) static <T1,
T2> Route path
(PathMatcher2<T1, T2> p, BiFunction<T1, T2, Route> inner) static <T> Route
path
(Unmarshaller<String, T> t, Function<T, Route> inner) static Route
static Route
static Route
static Route
pathEndOrSingleSlash
(Supplier<Route> inner) static Route
pathPrefix
(PathMatcher0 p, Supplier<Route> inner) static <T> Route
pathPrefix
(PathMatcher1<T> p, Function<T, Route> inner) static <T1,
T2> Route pathPrefix
(PathMatcher2<T1, T2> p, BiFunction<T1, T2, Route> inner) static <T> Route
pathPrefix
(Unmarshaller<String, T> t, Function<T, Route> inner) static Route
pathPrefix
(String segment, Supplier<Route> inner) static Route
pathPrefix
(Function<String, Route> inner) static Route
pathPrefixTest
(PathMatcher0 pm, Supplier<Route> inner) static <T1> Route
pathPrefixTest
(PathMatcher1<T1> pm, Function<T1, Route> inner) static <T1,
T2> Route pathPrefixTest
(PathMatcher2<T1, T2> pm, BiFunction<T1, T2, Route> inner) static Route
pathPrefixTest
(String segment, Supplier<Route> inner) static Route
pathSingleSlash
(Supplier<Route> inner) static Route
pathSuffix
(PathMatcher0 pm, Supplier<Route> inner) static <T1> Route
pathSuffix
(PathMatcher1<T1> pm, Function<T1, Route> inner) static <T1,
T2> Route pathSuffix
(PathMatcher2<T1, T2> pm, BiFunction<T1, T2, Route> inner) static Route
pathSuffix
(String segment, Supplier<Route> inner) static Route
pathSuffixTest
(PathMatcher0 pm, Supplier<Route> inner) static <T1> Route
pathSuffixTest
(PathMatcher1<T1> pm, Function<T1, Route> inner) static <T1,
T2> Route pathSuffixTest
(PathMatcher2<T1, T2> pm, BiFunction<T1, T2, Route> inner) static Route
pathSuffixTest
(String segment, Supplier<Route> inner) static Route
static <T> Route
static Route
static Route
rawPathPrefix
(PathMatcher0 pm, Supplier<Route> inner) static <T1> Route
rawPathPrefix
(PathMatcher1<T1> pm, Function<T1, Route> inner) static <T1,
T2> Route rawPathPrefix
(PathMatcher2<T1, T2> pm, BiFunction<T1, T2, Route> inner) static Route
rawPathPrefix
(String segment, Supplier<Route> inner) static Route
rawPathPrefixTest
(PathMatcher0 pm, Supplier<Route> inner) static <T1> Route
rawPathPrefixTest
(PathMatcher1<T1> pm, Function<T1, Route> inner) static <T1,
T2> Route rawPathPrefixTest
(PathMatcher2<T1, T2> pm, BiFunction<T1, T2, Route> inner) static Route
rawPathPrefixTest
(String segment, Supplier<Route> inner) static Route
recoverRejections
(Function<Iterable<Rejection>, RouteResult> f, Supplier<Route> inner) static Route
recoverRejectionsWith
(Function<Iterable<Rejection>, CompletionStage<RouteResult>> f, Supplier<Route> inner) static Route
redirect
(Uri uri, StatusCode redirectionType) static Route
redirectToNoTrailingSlashIfPresent
(StatusCode redirectionType, Supplier<Route> inner) static Route
redirectToTrailingSlashIfMissing
(StatusCode redirectionType, Supplier<Route> inner) static Route
reject()
static Route
static Route
static Route
rejectEmptyResponse
(Supplier<Route> inner) static <T> Route
request
(Unmarshaller<? super HttpRequest, T> unmarshaller, Function<T, Route> inner) static Route
requestEncodedWith
(HttpEncoding encoding, Supplier<Route> inner) static Route
requestEntityEmpty
(Supplier<Route> inner) static Route
requestEntityPresent
(Supplier<Route> inner) static Route
respondWithDefaultHeader
(HttpHeader responseHeader, Supplier<Route> inner) static Route
respondWithDefaultHeaders
(Iterable<HttpHeader> responseHeaders, Supplier<Route> inner) static Route
respondWithHeader
(HttpHeader responseHeader, Supplier<Route> inner) static Route
respondWithHeaders
(Iterable<HttpHeader> responseHeaders, Supplier<Route> inner) static Route
responseEncodingAccepted
(HttpEncoding encoding, Supplier<Route> inner) static Route
static Route
static Route
static Route
static Route
setCookie
(HttpCookie cookie, Supplier<Route> inner) static Route
setCookie
(Iterable<HttpCookie> cookies, Supplier<Route> inner) static Route
storeUploadedFile
(String fieldName, Function<FileInfo, File> destFn, BiFunction<FileInfo, File, Route> inner) static Route
storeUploadedFiles
(String fieldName, Function<FileInfo, File> destFn, Function<List<Map.Entry<FileInfo, File>>, Route> inner) static Route
toStrictEntity
(scala.concurrent.duration.FiniteDuration timeout, long maxBytes, Supplier<Route> inner) static Route
toStrictEntity
(scala.concurrent.duration.FiniteDuration timeout, Supplier<Route> inner) static Route
validate
(BooleanSupplier check, String errorMsg, Supplier<Route> inner) static Route
withExecutionContext
(scala.concurrent.ExecutionContextExecutor ec, Supplier<Route> inner) static Route
static Route
withMaterializer
(akka.stream.Materializer mat, Supplier<Route> inner) static RouteAdapter
withoutRequestTimeout
(Supplier<Route> inner) static Route
withoutSizeLimit
(Supplier<Route> inner) static Route
static Route
withRangeSupport
(Supplier<Route> inner) static RouteAdapter
withRequestTimeout
(scala.concurrent.duration.Duration timeout, Function<HttpRequest, HttpResponse> timeoutHandler, Supplier<Route> inner) static RouteAdapter
withRequestTimeout
(scala.concurrent.duration.Duration timeout, Supplier<Route> inner) static RouteAdapter
withRequestTimeoutResponse
(Function<HttpRequest, HttpResponse> timeoutHandler, Supplier<Route> inner) static Route
withSettings
(RoutingSettings s, Supplier<Route> inner) static Route
withSizeLimit
(long maxBytes, Supplier<Route> inner) Methods inherited from class akka.http.javadsl.server.directives.TimeoutDirectives
extractRequestTimeout, withoutRequestTimeout, withRequestTimeout, withRequestTimeout, withRequestTimeoutResponse
Methods inherited from class akka.http.javadsl.server.directives.WebSocketDirectives
extractOfferedWsProtocols, extractUpgradeToWebSocket, extractWebSocketUpgrade, handleWebSocketMessages, handleWebSocketMessagesForOptionalProtocol, handleWebSocketMessagesForProtocol
Methods inherited from class akka.http.javadsl.server.directives.SecurityDirectives
authenticateBasic, authenticateBasicAsync, authenticateBasicAsyncOptional, authenticateBasicOptional, authenticateBasicPF, authenticateBasicPFAsync, authenticateOAuth2, authenticateOAuth2Async, authenticateOAuth2AsyncOptional, authenticateOAuth2Optional, authenticateOrRejectWithChallenge, authenticateOrRejectWithChallenge, authorize, authorizeAsync, authorizeAsyncWithRequestContext, authorizeWithRequestContext, extractCredentials
Methods inherited from class akka.http.javadsl.server.directives.SchemeDirectives
extractScheme, scheme
Methods inherited from class akka.http.javadsl.server.directives.RouteDirectives
complete, complete, complete, complete, complete, complete, complete, complete, complete, complete, complete, complete, complete, complete, complete, complete, completeOK, completeOKWithFuture, completeOKWithFuture, completeOKWithFuture, completeOKWithFutureString, completeOKWithFutureString, completeWithFuture, completeWithFuture, completeWithFuture, completeWithFutureResponse, completeWithFutureStatus, completeWithFutureStatus, concat, concat, failWith, handle, handleSync, redirect, reject, reject, reject, route, route
Methods inherited from class akka.http.javadsl.server.directives.RespondWithDirectives
respondWithDefaultHeader, respondWithDefaultHeaders, respondWithHeader, respondWithHeaders
Methods inherited from class akka.http.javadsl.server.directives.RangeDirectives
withRangeSupport
Methods inherited from class akka.http.javadsl.server.directives.PathDirectives
ignoreTrailingSlash, path, path, path, path, path, path, pathEnd, pathEndOrSingleSlash, pathPrefix, pathPrefix, pathPrefix, pathPrefix, pathPrefix, pathPrefix, pathPrefixTest, pathPrefixTest, pathPrefixTest, pathPrefixTest, pathSingleSlash, pathSuffix, pathSuffix, pathSuffix, pathSuffix, pathSuffixTest, pathSuffixTest, pathSuffixTest, pathSuffixTest, rawPathPrefix, rawPathPrefix, rawPathPrefix, rawPathPrefix, rawPathPrefixTest, rawPathPrefixTest, rawPathPrefixTest, rawPathPrefixTest, redirectToNoTrailingSlashIfPresent, redirectToTrailingSlashIfMissing
Methods inherited from class akka.http.javadsl.server.directives.ParameterDirectives
parameter, parameter, parameterList, parameterList, parameterList, parameterMap, parameterMultiMap, parameterOptional, parameterOptional, parameterOrDefault, parameterRequiredValue
Methods inherited from class akka.http.javadsl.server.directives.MiscDirectives
extractClientIP, rejectEmptyResponse, requestEntityEmpty, requestEntityPresent, selectPreferredLanguage, validate, withoutSizeLimit, withSizeLimit
Methods inherited from class akka.http.javadsl.server.directives.MethodDirectives
delete, extractMethod, get, head, method, options, overrideMethodWithParameter, patch, post, put
Methods inherited from class akka.http.javadsl.server.directives.MarshallingDirectives
completeWith, entity, handleWith, request
Methods inherited from class akka.http.javadsl.server.directives.HostDirectives
extractHost, host, host, host, host
Methods inherited from class akka.http.javadsl.server.directives.AttributeDirectives
attribute, optionalAttribute
Methods inherited from class akka.http.javadsl.server.directives.HeaderDirectives
checkSameOrigin, headerValue, headerValueByName, headerValueByType, headerValuePF, optionalHeaderValue, optionalHeaderValueByName, optionalHeaderValueByType, optionalHeaderValuePF
Methods inherited from class akka.http.javadsl.server.directives.FutureDirectives
completeOrRecoverWith, onComplete, onComplete, onCompleteWithBreaker, onSuccess, onSuccess
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
-
Constructor Details
-
FramedEntityStreamingDirectives
public FramedEntityStreamingDirectives()
-
-
Method Details
-
mapRequest
-
mapRequestContext
public static Route mapRequestContext(Function<RequestContext, RequestContext> f, Supplier<Route> inner) -
mapRejections
-
mapResponse
-
mapResponseEntity
public static Route mapResponseEntity(Function<ResponseEntity, ResponseEntity> f, Supplier<Route> inner) -
mapResponseHeaders
public static Route mapResponseHeaders(Function<List<HttpHeader>, List<HttpHeader>> f, Supplier<Route> inner) -
mapInnerRoute
-
mapRouteResult
-
mapRouteResultPF
public static Route mapRouteResultPF(scala.PartialFunction<RouteResult, RouteResult> f, Supplier<Route> inner) -
mapRouteResultFuture
public static Route mapRouteResultFuture(Function<CompletionStage<RouteResult>, CompletionStage<RouteResult>> f, Supplier<Route> inner) -
mapRouteResultWith
public static Route mapRouteResultWith(Function<RouteResult, CompletionStage<RouteResult>> f, Supplier<Route> inner) -
mapRouteResultWithPF
public static Route mapRouteResultWithPF(scala.PartialFunction<RouteResult, CompletionStage<RouteResult>> f, Supplier<Route> inner) -
mapSettings
-
pass
-
provide
-
cancelRejection
-
cancelRejections
-
cancelRejections
-
recoverRejections
-
recoverRejectionsWith
public static Route recoverRejectionsWith(Function<Iterable<Rejection>, CompletionStage<RouteResult>> f, Supplier<Route> inner) -
mapUnmatchedPath
-
extractUnmatchedPath
-
extractMatchedPath
-
extractRequest
-
extractUri
-
extractEntity
-
extractMaterializer
-
extractActorSystem
-
extractExecutionContext
-
extract
-
withLog
-
withExecutionContext
-
withMaterializer
-
withSettings
-
extractLog
-
extractParserSettings
-
extractSettings
-
extractRequestContext
-
extractDataBytes
public static RouteAdapter extractDataBytes(Function<akka.stream.javadsl.Source<akka.util.ByteString, Object>, Route> inner) -
extractRequestEntity
-
extractStrictEntity
public static Route extractStrictEntity(scala.concurrent.duration.FiniteDuration timeout, Function<HttpEntity.Strict, Route> inner) -
extractStrictEntity
public static Route extractStrictEntity(scala.concurrent.duration.FiniteDuration timeout, long maxBytes, Function<HttpEntity.Strict, Route> inner) -
toStrictEntity
-
toStrictEntity
-
conditional
-
conditional
-
conditional
-
conditional
-
responseEncodingAccepted
-
encodeResponse
-
encodeResponseWith
-
decodeRequestWith
-
requestEncodedWith
-
decodeRequestWith
-
decodeRequest
-
withPrecompressedMediaTypeSupport
-
cookie
-
optionalCookie
-
setCookie
-
setCookie
-
deleteCookie
-
deleteCookie
-
deleteCookie
-
deleteCookie
-
deleteCookie
-
logRequest
-
logRequest
-
logRequest
-
logResult
-
logResult
-
logResult
public static RouteAdapter logResult(Function<HttpResponse, LogEntry> showSuccess, Function<List<Rejection>, LogEntry> showRejection, Supplier<Route> inner) -
logRequestResult
public static RouteAdapter logRequestResult(BiFunction<HttpRequest, HttpResponse, LogEntry> showSuccess, BiFunction<HttpRequest, List<Rejection>, LogEntry> showRejection, Supplier<Route> inner) -
logRequestResultOptional
public static RouteAdapter logRequestResultOptional(BiFunction<HttpRequest, HttpResponse, Optional<LogEntry>> showSuccess, BiFunction<HttpRequest, List<Rejection>, Optional<LogEntry>> showRejection, Supplier<Route> inner) -
handleExceptions
-
handleRejections
-
getFromResource
-
getFromResource
-
getFromResource
-
getFromResource
-
getFromResourceDirectory
-
getFromResourceDirectory
-
getFromResourceDirectory
-
getFromResourceDirectory
public static Route getFromResourceDirectory(String directoryName, ContentTypeResolver resolver, ClassLoader classLoader) -
getFromFile
-
getFromFile
-
getFromFile
-
getFromFile
-
getFromFile
-
getFromDirectory
-
getFromDirectory
-
getFromBrowseableDirectory
public static Route getFromBrowseableDirectory(String directory, DirectoryRenderer renderer, ContentTypeResolver resolver) -
getFromBrowseableDirectory
-
getFromBrowseableDirectory
-
getFromBrowseableDirectory
-
getFromBrowseableDirectories
public static Route getFromBrowseableDirectories(Iterable<String> directories, DirectoryRenderer renderer, ContentTypeResolver resolver) -
getFromBrowseableDirectories
public static Route getFromBrowseableDirectories(Iterable<String> directories, DirectoryRenderer renderer) -
getFromBrowseableDirectories
public static Route getFromBrowseableDirectories(Iterable<String> directories, ContentTypeResolver resolver) -
getFromBrowseableDirectories
-
listDirectoryContents
-
listDirectoryContents
public static Route listDirectoryContents(DirectoryRenderer directoryRenderer, scala.collection.immutable.Seq<String> directories) -
defaultDirectoryRenderer
-
defaultContentTypeResolver
-
getFromBrowseableDirectories
-
listDirectoryContents
-
listDirectoryContents
public static Route listDirectoryContents(DirectoryRenderer directoryRenderer, String... directories) -
storeUploadedFile
-
storeUploadedFiles
-
fileUpload
-
fileUploadAll
-
formField
-
formFieldOptional
-
formFieldList
-
formField
-
formFieldOptional
-
formFieldList
-
formFieldMap
-
formFieldMultiMap
-
formFieldList
-
onComplete
public static <T> RouteAdapter onComplete(Supplier<CompletionStage<T>> f, Function<scala.util.Try<T>, Route> inner) -
onComplete
public static <T> RouteAdapter onComplete(CompletionStage<T> cs, Function<scala.util.Try<T>, Route> inner) -
onCompleteWithBreaker
public static <T> RouteAdapter onCompleteWithBreaker(akka.pattern.CircuitBreaker breaker, Supplier<CompletionStage<T>> f, Function<scala.util.Try<T>, Route> inner) -
onSuccess
-
onSuccess
-
completeOrRecoverWith
public static <T> Route completeOrRecoverWith(Supplier<CompletionStage<T>> f, Marshaller<T, RequestEntity> marshaller, Function<Throwable, Route> inner) -
checkSameOrigin
-
headerValue
public static <T> RouteAdapter headerValue(Function<HttpHeader, Optional<T>> f, Function<T, Route> inner) -
headerValuePF
public static <T> RouteAdapter headerValuePF(scala.PartialFunction<HttpHeader, T> pf, Function<T, Route> inner) -
headerValueByName
-
headerValueByType
public static <T extends HttpHeader> RouteAdapter headerValueByType(Class<T> t, Function<T, Route> inner) -
optionalHeaderValue
public static <T> RouteAdapter optionalHeaderValue(Function<HttpHeader, Optional<T>> f, Function<Optional<T>, Route> inner) -
optionalHeaderValuePF
public static <T> RouteAdapter optionalHeaderValuePF(scala.PartialFunction<HttpHeader, T> pf, Function<Optional<T>, Route> inner) -
optionalHeaderValueByName
-
optionalHeaderValueByType
public static <T extends HttpHeader> RouteAdapter optionalHeaderValueByType(Class<T> t, Function<Optional<T>, Route> inner) -
attribute
-
optionalAttribute
public static <T> RouteAdapter optionalAttribute(AttributeKey<T> key, Function<Optional<T>, Route> inner) -
extractHost
-
host
-
host
-
host
-
host
-
request
public static <T> Route request(Unmarshaller<? super HttpRequest, T> unmarshaller, Function<T, Route> inner) -
entity
public static <T> Route entity(Unmarshaller<? super HttpEntity, T> unmarshaller, Function<T, Route> inner) -
completeWith
public static <T> Route completeWith(Marshaller<T, ? extends HttpResponse> marshaller, Consumer<Consumer<T>> inner) -
handleWith
public static <T,R> Route handleWith(Unmarshaller<? super HttpEntity, T> unmarshaller, Marshaller<R, ? extends HttpResponse> marshaller, Function<T, R> inner) -
delete
-
get
-
head
-
options
-
patch
-
post
-
put
-
extractMethod
-
method
-
overrideMethodWithParameter
-
validate
-
extractClientIP
-
requestEntityEmpty
-
requestEntityPresent
-
rejectEmptyResponse
-
withSizeLimit
-
withoutSizeLimit
-
selectPreferredLanguage
-
parameter
-
parameterOptional
-
parameterRequiredValue
-
parameterList
-
parameter
-
parameterOptional
-
parameterOrDefault
-
parameterList
-
parameterMap
-
parameterMultiMap
-
parameterList
-
pathEnd
-
pathEndOrSingleSlash
-
pathSingleSlash
-
path
-
path
-
path
-
path
-
path
-
pathPrefix
-
pathPrefix
-
pathPrefix
-
pathPrefix
-
pathPrefix
-
rawPathPrefix
-
rawPathPrefix
-
rawPathPrefix
-
rawPathPrefix
-
pathPrefixTest
-
pathPrefixTest
-
pathPrefixTest
-
pathPrefixTest
-
rawPathPrefixTest
-
rawPathPrefixTest
-
rawPathPrefixTest
-
rawPathPrefixTest
public static <T1,T2> Route rawPathPrefixTest(PathMatcher2<T1, T2> pm, BiFunction<T1, T2, Route> inner) -
pathSuffix
-
pathSuffix
-
pathSuffix
-
pathSuffix
-
pathSuffixTest
-
pathSuffixTest
-
pathSuffixTest
-
pathSuffixTest
-
redirectToTrailingSlashIfMissing
public static Route redirectToTrailingSlashIfMissing(StatusCode redirectionType, Supplier<Route> inner) -
redirectToNoTrailingSlashIfPresent
public static Route redirectToNoTrailingSlashIfPresent(StatusCode redirectionType, Supplier<Route> inner) -
pathPrefix
-
path
-
ignoreTrailingSlash
-
withRangeSupport
-
respondWithHeader
-
respondWithDefaultHeader
-
respondWithHeaders
-
respondWithDefaultHeaders
public static Route respondWithDefaultHeaders(Iterable<HttpHeader> responseHeaders, Supplier<Route> inner) -
route
-
concat
-
reject
-
reject
-
redirect
-
failWith
-
complete
-
complete
-
complete
-
complete
-
complete
public static <T> RouteAdapter complete(StatusCode status, Iterable<HttpHeader> headers, T value, Marshaller<T, RequestEntity> marshaller) -
complete
public static RouteAdapter complete(StatusCode status, Iterable<HttpHeader> headers, ResponseEntity entity) -
complete
public static RouteAdapter complete(StatusCode status, Iterable<HttpHeader> headers, RequestEntity entity) -
complete
public static <T> RouteAdapter complete(StatusCode status, T value, Marshaller<T, RequestEntity> marshaller) -
complete
-
complete
-
complete
-
complete
public static <T> RouteAdapter complete(Iterable<HttpHeader> headers, T value, Marshaller<T, RequestEntity> marshaller) -
complete
-
complete
-
completeOK
-
complete
-
complete
-
completeWithFutureResponse
-
completeOKWithFutureString
-
completeWithFutureStatus
-
completeOKWithFuture
public static <T> RouteAdapter completeOKWithFuture(scala.concurrent.Future<T> value, Marshaller<T, RequestEntity> marshaller) -
completeWithFuture
public static <T> RouteAdapter completeWithFuture(scala.concurrent.Future<T> value, Marshaller<T, HttpResponse> marshaller) -
completeWithFuture
-
completeOKWithFuture
-
completeOKWithFutureString
-
completeWithFutureStatus
-
completeOKWithFuture
public static <T> RouteAdapter completeOKWithFuture(CompletionStage<T> value, Marshaller<T, RequestEntity> marshaller) -
completeWithFuture
public static <T> RouteAdapter completeWithFuture(CompletionStage<T> value, Marshaller<T, HttpResponse> marshaller) -
handle
public static Route handle(akka.japi.function.Function<HttpRequest, CompletionStage<HttpResponse>> handler) -
handleSync
-
route
-
concat
-
reject
-
extractScheme
-
scheme
-
extractCredentials
-
authenticateBasic
-
authenticateBasicPF
-
authenticateBasicPFAsync
public static <T> Route authenticateBasicPFAsync(String realm, scala.PartialFunction<Optional<SecurityDirectives.ProvidedCredentials>, CompletionStage<T>> authenticator, Function<T, Route> inner) -
authenticateBasicOptional
-
authenticateBasicAsync
public static <T> Route authenticateBasicAsync(String realm, Function<Optional<SecurityDirectives.ProvidedCredentials>, CompletionStage<Optional<T>>> authenticator, Function<T, Route> inner) -
authenticateBasicAsyncOptional
public static <T> Route authenticateBasicAsyncOptional(String realm, Function<Optional<SecurityDirectives.ProvidedCredentials>, CompletionStage<Optional<T>>> authenticator, Function<Optional<T>, Route> inner) -
authenticateOAuth2
-
authenticateOAuth2Optional
-
authenticateOAuth2Async
public static <T> Route authenticateOAuth2Async(String realm, Function<Optional<SecurityDirectives.ProvidedCredentials>, CompletionStage<Optional<T>>> authenticator, Function<T, Route> inner) -
authenticateOAuth2AsyncOptional
public static <T> Route authenticateOAuth2AsyncOptional(String realm, Function<Optional<SecurityDirectives.ProvidedCredentials>, CompletionStage<Optional<T>>> authenticator, Function<Optional<T>, Route> inner) -
authenticateOrRejectWithChallenge
public static <T> Route authenticateOrRejectWithChallenge(Function<Optional<HttpCredentials>, CompletionStage<scala.util.Either<HttpChallenge, T>>> authenticator, Function<T, Route> inner) -
authenticateOrRejectWithChallenge
public static <C extends HttpCredentials,T> Route authenticateOrRejectWithChallenge(Class<C> c, Function<Optional<C>, CompletionStage<scala.util.Either<HttpChallenge, T>>> authenticator, Function<T, Route> inner) -
authorize
-
authorizeWithRequestContext
public static Route authorizeWithRequestContext(akka.japi.function.Function<RequestContext, Object> check, Supplier<Route> inner) -
authorizeAsync
-
authorizeAsyncWithRequestContext
public static Route authorizeAsyncWithRequestContext(akka.japi.function.Function<RequestContext, CompletionStage<Object>> check, Supplier<Route> inner) -
extractUpgradeToWebSocket
-
extractWebSocketUpgrade
-
extractOfferedWsProtocols
-
handleWebSocketMessages
-
handleWebSocketMessagesForProtocol
-
handleWebSocketMessagesForOptionalProtocol
-
extractRequestTimeout
public static RouteAdapter extractRequestTimeout(Function<scala.concurrent.duration.Duration, Route> inner) -
withRequestTimeout
public static RouteAdapter withRequestTimeout(scala.concurrent.duration.Duration timeout, Supplier<Route> inner) -
withRequestTimeout
public static RouteAdapter withRequestTimeout(scala.concurrent.duration.Duration timeout, Function<HttpRequest, HttpResponse> timeoutHandler, Supplier<Route> inner) -
withoutRequestTimeout
-
withRequestTimeoutResponse
public static RouteAdapter withRequestTimeoutResponse(Function<HttpRequest, HttpResponse> timeoutHandler, Supplier<Route> inner) -
entityAsSourceOf
public <T> Route entityAsSourceOf(Unmarshaller<akka.util.ByteString, T> um, EntityStreamingSupport support, Function<akka.stream.javadsl.Source<T, akka.NotUsed>, Route> inner) -
completeWithSource
public <T,M> Route completeWithSource(akka.stream.javadsl.Source<T, M> source, Marshaller<T, akka.util.ByteString> m, EntityStreamingSupport support) -
completeOKWithSource
public <T,M> Route completeOKWithSource(akka.stream.javadsl.Source<T, M> source, Marshaller<T, RequestEntity> m, EntityStreamingSupport support)
-