Class Directives
java.lang.Object
org.apache.pekko.http.javadsl.server.Directives
Collects all default directives into one class for simple importing of static functions.
See pekko.http.scaladsl.server.Directives for ScalaDSL equivalent of this class.
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic <A,B> Route allOf(Function<Function<A, Route>, Route> first, Function<Function<B, Route>, Route> second, BiFunction<A, B, Route> inner) Nests two 1-argument directives together Usage example:allOf(this::extractScheme, this::extractMethod, (scheme, method) -> complete("You did a " + method.name() + " using " + scheme))static <A> RouteallOf(Function<Supplier<Route>, Route> first, Function<Function<A, Route>, Route> second, Function<A, Route> inner) Nests one 0-argument and 1-argument directives together Usage example:allOf(bindParameter(this::pathPrefix, "guess"), this::extractMethod, method -> complete("You did a " + method.name()))static RouteallOf(Function<Supplier<Route>, Route> first, Function<Supplier<Route>, Route> second, Supplier<Route> inner) Nests two 0-argument directives together Usage example:allOf(bindParameter(this::pathPrefix, "alice"), bindParameter(this::path, "bob"), () -> complete("Charlie!"))static <A> RouteanyOf(Function<Function<A, Route>, Route> first, Function<Function<A, Route>, Route> second, Function<A, Route> inner) Composes two 1-argument directives (directives whose inner route takes a parameter) which share the same inner route.static RouteanyOf(Function<Supplier<Route>, Route> first, Function<Supplier<Route>, Route> second, Supplier<Route> inner) Composes two 0-argument directives which share the same inner Route.static <T> RouteAdapterattribute(AttributeKey<T> key, Function<T, Route> inner) static <T> RouteauthenticateBasic(String realm, Function<Optional<SecurityDirectives.ProvidedCredentials>, Optional<T>> authenticator, Function<T, Route> inner) static <T> RouteauthenticateBasicAsync(String realm, Function<Optional<SecurityDirectives.ProvidedCredentials>, CompletionStage<Optional<T>>> authenticator, Function<T, Route> inner) static <T> RouteauthenticateBasicAsyncOptional(String realm, Function<Optional<SecurityDirectives.ProvidedCredentials>, CompletionStage<Optional<T>>> authenticator, Function<Optional<T>, Route> inner) static <T> RouteauthenticateBasicOptional(String realm, Function<Optional<SecurityDirectives.ProvidedCredentials>, Optional<T>> authenticator, Function<Optional<T>, Route> inner) static <T> RouteauthenticateBasicPF(String realm, scala.PartialFunction<Optional<SecurityDirectives.ProvidedCredentials>, T> authenticator, Function<T, Route> inner) static <T> RouteauthenticateBasicPFAsync(String realm, scala.PartialFunction<Optional<SecurityDirectives.ProvidedCredentials>, CompletionStage<T>> authenticator, Function<T, Route> inner) static <T> RouteauthenticateOAuth2(String realm, Function<Optional<SecurityDirectives.ProvidedCredentials>, Optional<T>> authenticator, Function<T, Route> inner) static <T> RouteauthenticateOAuth2Async(String realm, Function<Optional<SecurityDirectives.ProvidedCredentials>, CompletionStage<Optional<T>>> authenticator, Function<T, Route> inner) static <T> RouteauthenticateOAuth2AsyncOptional(String realm, Function<Optional<SecurityDirectives.ProvidedCredentials>, CompletionStage<Optional<T>>> authenticator, Function<Optional<T>, Route> inner) static <T> RouteauthenticateOAuth2Optional(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> RouteauthenticateOrRejectWithChallenge(Function<Optional<HttpCredentials>, CompletionStage<scala.util.Either<HttpChallenge, T>>> authenticator, Function<T, Route> inner) static Routestatic RouteauthorizeAsync(Supplier<CompletionStage<Object>> check, Supplier<Route> inner) static RouteauthorizeAsyncWithRequestContext(org.apache.pekko.japi.function.Function<RequestContext, CompletionStage<Object>> check, Supplier<Route> inner) static RouteauthorizeWithRequestContext(org.apache.pekko.japi.function.Function<RequestContext, Object> check, Supplier<Route> inner) static RoutecancelRejection(Rejection rejection, Supplier<Route> inner) static RoutecancelRejections(Iterable<Class<?>> classes, Supplier<Route> inner) static RoutecancelRejections(Predicate<Rejection> filter, Supplier<Route> inner) static RoutecheckSameOrigin(HttpOriginRange allowed, Supplier<Route> inner) static RouteAdaptercomplete(Iterable<HttpHeader> headers, RequestEntity entity) static RouteAdaptercomplete(Iterable<HttpHeader> headers, ResponseEntity entity) static <T> RouteAdaptercomplete(Iterable<HttpHeader> headers, T value, Marshaller<T, RequestEntity> marshaller) static Routestatic Routecomplete(HttpResponse response) static RouteAdaptercomplete(RequestEntity entity) static RouteAdaptercomplete(ResponseEntity entity) static Routecomplete(StatusCode status) static RouteAdaptercomplete(StatusCode status, Iterable<HttpHeader> headers, RequestEntity entity) static RouteAdaptercomplete(StatusCode status, Iterable<HttpHeader> headers, ResponseEntity entity) static <T> RouteAdaptercomplete(StatusCode status, Iterable<HttpHeader> headers, T value, Marshaller<T, RequestEntity> marshaller) static RouteAdaptercomplete(StatusCode status, String entity) static RouteAdaptercomplete(StatusCode status, RequestEntity entity) static RouteAdaptercomplete(StatusCode status, ResponseEntity entity) static <T> RouteAdaptercomplete(StatusCode status, T value, Marshaller<T, RequestEntity> marshaller) static <T> RouteAdaptercomplete(T value, Marshaller<T, HttpResponse> marshaller) static <T> RouteAdaptercompleteOK(T value, Marshaller<T, RequestEntity> marshaller) static RouteAdapterstatic <T> RouteAdaptercompleteOKWithFuture(CompletionStage<T> value, Marshaller<T, RequestEntity> marshaller) static <T> RouteAdaptercompleteOKWithFuture(scala.concurrent.Future<T> value, Marshaller<T, RequestEntity> marshaller) static RouteAdapterstatic RouteAdaptercompleteOKWithFutureString(scala.concurrent.Future<String> value) static <T,M> Route completeOKWithSource(org.apache.pekko.stream.javadsl.Source<T, M> source, Marshaller<T, RequestEntity> m, EntityStreamingSupport support) static <T> RoutecompleteOrRecoverWith(Supplier<CompletionStage<T>> f, Marshaller<T, RequestEntity> marshaller, Function<Throwable, Route> inner) static <T> RoutecompleteWith(Marshaller<T, ? extends HttpResponse> marshaller, Consumer<Consumer<T>> inner) static RouteAdapterstatic <T> RouteAdaptercompleteWithFuture(CompletionStage<T> value, Marshaller<T, HttpResponse> marshaller) static <T> RouteAdaptercompleteWithFuture(scala.concurrent.Future<T> value, Marshaller<T, HttpResponse> marshaller) static RouteAdaptercompleteWithFutureResponse(scala.concurrent.Future<HttpResponse> value) static Routestatic RoutecompleteWithFutureStatus(scala.concurrent.Future<StatusCode> status) static <T,M> Route completeWithSource(org.apache.pekko.stream.javadsl.Source<T, M> source, Marshaller<T, org.apache.pekko.util.ByteString> m, EntityStreamingSupport support) static Routestatic Routestatic Routestatic Routeconditional(DateTime lastModified, Supplier<Route> inner) static Routeconditional(EntityTag eTag, Supplier<Route> inner) static Routeconditional(EntityTag eTag, DateTime lastModified, Supplier<Route> inner) static Routecookie(String name, Function<HttpCookiePair, Route> inner) static RoutedecodeRequest(Supplier<Route> inner) static RoutedecodeRequestWith(Iterable<Coder> coders, Supplier<Route> inner) static RoutedecodeRequestWith(Coder coder, Supplier<Route> inner) static ContentTypeResolverstatic DirectoryRendererstatic Routestatic RoutedeleteCookie(Iterable<HttpCookie> cookies, Supplier<Route> inner) static Routestatic RoutedeleteCookie(String name, String domain, Supplier<Route> inner) static RoutedeleteCookie(String name, Supplier<Route> inner) static RoutedeleteCookie(HttpCookie cookie, Supplier<Route> inner) static RouteencodeResponse(Supplier<Route> inner) static RouteencodeResponseWith(Iterable<Coder> coders, Supplier<Route> inner) static <T> Routeentity(Unmarshaller<? super HttpEntity, T> unmarshaller, Function<T, Route> inner) static <T> RouteentityAsSourceOf(Unmarshaller<org.apache.pekko.util.ByteString, T> um, EntityStreamingSupport support, Function<org.apache.pekko.stream.javadsl.Source<T, org.apache.pekko.NotUsed>, Route> inner) static <T> Routeextract(Function<RequestContext, T> extract, Function<T, Route> inner) static RouteextractActorSystem(Function<org.apache.pekko.actor.ActorSystem, Route> inner) static RouteextractClientIP(Function<RemoteAddress, Route> inner) static Routestatic RouteAdapterextractDataBytes(Function<org.apache.pekko.stream.javadsl.Source<org.apache.pekko.util.ByteString, Object>, Route> inner) static RouteextractEntity(Function<RequestEntity, Route> inner) static RouteextractExecutionContext(Function<scala.concurrent.ExecutionContextExecutor, Route> inner) static RouteextractHost(Function<String, Route> inner) static RouteextractLog(Function<org.apache.pekko.event.LoggingAdapter, Route> inner) static RouteAdapterextractMatchedPath(Function<String, Route> inner) static RouteextractMaterializer(Function<org.apache.pekko.stream.Materializer, Route> inner) static RouteAdapterextractMethod(Function<HttpMethod, Route> inner) static RouteextractOfferedWsProtocols(Function<List<String>, Route> inner) static RouteAdapterstatic RouteAdapterextractRequest(Function<HttpRequest, Route> inner) static RouteAdapterstatic Routestatic RouteAdapterextractRequestTimeout(Function<Duration, Route> inner) static RouteextractScheme(Function<String, Route> inner) static RouteAdapterextractSettings(Function<RoutingSettings, Route> inner) static RouteextractStrictEntity(Duration timeout, long maxBytes, Function<HttpEntity.Strict, Route> inner) static RouteextractStrictEntity(Duration timeout, Function<HttpEntity.Strict, Route> inner) static RouteextractStrictEntity(scala.concurrent.duration.FiniteDuration timeout, long maxBytes, Function<HttpEntity.Strict, Route> inner) static RouteextractStrictEntity(scala.concurrent.duration.FiniteDuration timeout, Function<HttpEntity.Strict, Route> inner) static RouteAdapterextractUnmatchedPath(Function<String, Route> inner) static RouteAdapterextractUri(Function<Uri, Route> inner) static Routestatic Routestatic RoutefileUpload(String fieldName, BiFunction<FileInfo, org.apache.pekko.stream.javadsl.Source<org.apache.pekko.util.ByteString, Object>, Route> inner) static RoutefileUploadAll(String fieldName, Function<List<Map.Entry<FileInfo, org.apache.pekko.stream.javadsl.Source<org.apache.pekko.util.ByteString, Object>>>, Route> inner) static Routestatic <T> Routestatic Routestatic Routestatic <T> RouteformFieldList(Unmarshaller<String, T> t, String name, Function<List<T>, Route> inner) static Routestatic Routestatic Routestatic <T> RouteformFieldOptional(Unmarshaller<String, T> t, String name, Function<Optional<T>, Route> inner) static Routestatic RoutegetFromBrowseableDirectories(String... directories) static RoutegetFromBrowseableDirectories(scala.collection.immutable.Seq<String> directories) static RoutegetFromBrowseableDirectory(String directory) static RoutegetFromBrowseableDirectory(String directory, ContentTypeResolver resolver) static RoutegetFromBrowseableDirectory(String directory, DirectoryRenderer renderer) static RoutegetFromBrowseableDirectory(String directory, DirectoryRenderer renderer, ContentTypeResolver resolver) static RoutegetFromDirectory(String directoryPath) static RoutegetFromDirectory(String directoryPath, ContentTypeResolver resolver) static RoutegetFromFile(File file) static RoutegetFromFile(File file, ContentType contentType) static RoutegetFromFile(File file, ContentTypeResolver resolver) static RoutegetFromFile(String file) static RoutegetFromFile(String file, ContentTypeResolver resolver) static RoutegetFromResource(String path) static RoutegetFromResource(String path, ContentType contentType) static RoutegetFromResource(String path, ContentType contentType, ClassLoader classLoader) static RoutegetFromResource(String path, ContentTypeResolver resolver) static RoutegetFromResourceDirectory(String directoryName) static RoutegetFromResourceDirectory(String directoryName, ClassLoader classLoader) static RoutegetFromResourceDirectory(String directoryName, ContentTypeResolver resolver) static RoutegetFromResourceDirectory(String directoryName, ContentTypeResolver resolver, ClassLoader classLoader) static Routehandle(org.apache.pekko.japi.function.Function<HttpRequest, CompletionStage<HttpResponse>> handler) static RouteAdapterhandleExceptions(ExceptionHandler handler, Supplier<Route> inner) static RouteAdapterhandleRejections(RejectionHandler handler, Supplier<Route> inner) static RoutehandleSync(org.apache.pekko.japi.function.Function<HttpRequest, HttpResponse> handler) static <T> RoutehandleWebSocketMessages(org.apache.pekko.stream.javadsl.Flow<Message, Message, T> handler) static <T> RoutehandleWebSocketMessagesForOptionalProtocol(org.apache.pekko.stream.javadsl.Flow<Message, Message, T> handler, Optional<String> subprotocol) static <T> RoutehandleWebSocketMessagesForProtocol(org.apache.pekko.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 Routestatic <T> RouteAdapterheaderValue(Function<HttpHeader, Optional<T>> f, Function<T, Route> inner) static RouteAdapterheaderValueByName(String headerName, Function<String, Route> inner) static <T extends HttpHeader>
RouteAdapterheaderValueByType(Class<T> t, Function<T, Route> inner) static <T> RouteAdapterheaderValuePF(scala.PartialFunction<HttpHeader, T> pf, Function<T, Route> inner) static Routestatic Routestatic Routestatic Routestatic RouteignoreTrailingSlash(Supplier<Route> inner) static RoutelistDirectoryContents(String... directories) static RoutelistDirectoryContents(DirectoryRenderer directoryRenderer, String... directories) static RoutelistDirectoryContents(DirectoryRenderer directoryRenderer, scala.collection.immutable.Seq<String> directories) static RoutelistDirectoryContents(scala.collection.immutable.Seq<String> directories) static RoutelogRequest(String marker, Supplier<Route> inner) static RoutelogRequest(String marker, org.apache.pekko.event.Logging.LogLevel level, Supplier<Route> inner) static RoutelogRequest(Function<HttpRequest, LogEntry> show, Supplier<Route> inner) static RouteAdapterlogRequestResult(BiFunction<HttpRequest, HttpResponse, LogEntry> showSuccess, BiFunction<HttpRequest, List<Rejection>, LogEntry> showRejection, Supplier<Route> inner) static RouteAdapterlogRequestResultOptional(BiFunction<HttpRequest, HttpResponse, Optional<LogEntry>> showSuccess, BiFunction<HttpRequest, List<Rejection>, Optional<LogEntry>> showRejection, Supplier<Route> inner) static Routestatic Routestatic RouteAdapterlogResult(Function<HttpResponse, LogEntry> showSuccess, Function<List<Rejection>, LogEntry> showRejection, Supplier<Route> inner) static Routestatic Routestatic RoutemapRequest(Function<HttpRequest, HttpRequest> f, Supplier<Route> inner) static RoutemapRequestContext(Function<RequestContext, RequestContext> f, Supplier<Route> inner) static RoutemapResponse(Function<HttpResponse, HttpResponse> f, Supplier<Route> inner) static RoutemapResponseEntity(Function<ResponseEntity, ResponseEntity> f, Supplier<Route> inner) static RoutemapResponseHeaders(Function<List<HttpHeader>, List<HttpHeader>> f, Supplier<Route> inner) static RoutemapRouteResult(Function<RouteResult, RouteResult> f, Supplier<Route> inner) static RoutemapRouteResultFuture(Function<CompletionStage<RouteResult>, CompletionStage<RouteResult>> f, Supplier<Route> inner) static RoutemapRouteResultPF(scala.PartialFunction<RouteResult, RouteResult> f, Supplier<Route> inner) static RoutemapRouteResultWith(Function<RouteResult, CompletionStage<RouteResult>> f, Supplier<Route> inner) static RoutemapRouteResultWithPF(scala.PartialFunction<RouteResult, CompletionStage<RouteResult>> f, Supplier<Route> inner) static RoutemapSettings(Function<RoutingSettings, RoutingSettings> f, Supplier<Route> inner) static Routestatic Routemethod(HttpMethod method, Supplier<Route> inner) static <T> RouteAdapteronComplete(CompletionStage<T> cs, Function<scala.util.Try<T>, Route> inner) static <T> RouteAdapteronComplete(Supplier<CompletionStage<T>> f, Function<scala.util.Try<T>, Route> inner) static <T> RouteAdapteronCompleteWithBreaker(org.apache.pekko.pattern.CircuitBreaker breaker, Supplier<CompletionStage<T>> f, Function<scala.util.Try<T>, Route> inner) static <T> RouteAdapteronSuccess(CompletionStage<T> cs, Function<T, Route> inner) static <T> RouteAdapteronSuccess(Supplier<CompletionStage<T>> f, Function<T, Route> inner) static <T> RouteAdapteroptionalAttribute(AttributeKey<T> key, Function<Optional<T>, Route> inner) static RouteoptionalCookie(String name, Function<Optional<HttpCookiePair>, Route> inner) static <T> RouteAdapteroptionalHeaderValue(Function<HttpHeader, Optional<T>> f, Function<Optional<T>, Route> inner) static RouteAdapterstatic <T extends HttpHeader>
RouteAdapteroptionalHeaderValueByType(Class<T> t, Function<Optional<T>, Route> inner) static <T> RouteAdapteroptionalHeaderValuePF(scala.PartialFunction<HttpHeader, T> pf, Function<Optional<T>, Route> inner) static Routestatic RouteoverrideMethodWithParameter(String paramName, Supplier<Route> inner) static Routestatic <T> Routestatic Routestatic Routestatic <T> RouteparameterList(Unmarshaller<String, T> t, String name, Function<List<T>, Route> inner) static Routestatic Routestatic Routestatic <T> RouteparameterOptional(Unmarshaller<String, T> t, String name, Function<Optional<T>, Route> inner) static <T> RouteparameterOrDefault(Unmarshaller<String, T> t, T defaultValue, String name, Function<T, Route> inner) static <T> RouteparameterRequiredValue(Unmarshaller<String, T> t, T requiredValue, String name, Supplier<Route> inner) static Routestatic Routestatic Routestatic Routestatic Routepath(PathMatcher0 p, Supplier<Route> inner) static <T> Routepath(PathMatcher1<T> p, Function<T, Route> inner) static <T1,T2> Route path(PathMatcher2<T1, T2> p, BiFunction<T1, T2, Route> inner) static <T> Routepath(Unmarshaller<String, T> t, Function<T, Route> inner) static Routestatic RoutepathEndOrSingleSlash(Supplier<Route> inner) static RoutepathPrefix(String segment, Supplier<Route> inner) static RoutepathPrefix(Function<String, Route> inner) static RoutepathPrefix(PathMatcher0 p, Supplier<Route> inner) static <T> RoutepathPrefix(PathMatcher1<T> p, Function<T, Route> inner) static <T1,T2> Route pathPrefix(PathMatcher2<T1, T2> p, BiFunction<T1, T2, Route> inner) static <T> RoutepathPrefix(Unmarshaller<String, T> t, Function<T, Route> inner) static RoutepathPrefixTest(String segment, Supplier<Route> inner) static RoutepathPrefixTest(PathMatcher0 pm, Supplier<Route> inner) static <T1> RoutepathPrefixTest(PathMatcher1<T1> pm, Function<T1, Route> inner) static <T1,T2> Route pathPrefixTest(PathMatcher2<T1, T2> pm, BiFunction<T1, T2, Route> inner) static RoutepathSingleSlash(Supplier<Route> inner) static RoutepathSuffix(String segment, Supplier<Route> inner) static RoutepathSuffix(PathMatcher0 pm, Supplier<Route> inner) static <T1> RoutepathSuffix(PathMatcher1<T1> pm, Function<T1, Route> inner) static <T1,T2> Route pathSuffix(PathMatcher2<T1, T2> pm, BiFunction<T1, T2, Route> inner) static RoutepathSuffixTest(String segment, Supplier<Route> inner) static RoutepathSuffixTest(PathMatcher0 pm, Supplier<Route> inner) static <T1> RoutepathSuffixTest(PathMatcher1<T1> pm, Function<T1, Route> inner) static <T1,T2> Route pathSuffixTest(PathMatcher2<T1, T2> pm, BiFunction<T1, T2, Route> inner) static Routestatic <T> Routestatic Routestatic RouterawPathPrefix(String segment, Supplier<Route> inner) static RouterawPathPrefix(PathMatcher0 pm, Supplier<Route> inner) static <T1> RouterawPathPrefix(PathMatcher1<T1> pm, Function<T1, Route> inner) static <T1,T2> Route rawPathPrefix(PathMatcher2<T1, T2> pm, BiFunction<T1, T2, Route> inner) static RouterawPathPrefixTest(String segment, Supplier<Route> inner) static RouterawPathPrefixTest(PathMatcher0 pm, Supplier<Route> inner) static <T1> RouterawPathPrefixTest(PathMatcher1<T1> pm, Function<T1, Route> inner) static <T1,T2> Route rawPathPrefixTest(PathMatcher2<T1, T2> pm, BiFunction<T1, T2, Route> inner) static RouterecoverRejections(Function<Iterable<Rejection>, RouteResult> f, Supplier<Route> inner) static RouterecoverRejectionsWith(Function<Iterable<Rejection>, CompletionStage<RouteResult>> f, Supplier<Route> inner) static Routeredirect(Uri uri, StatusCode redirectionType) static RouteredirectToNoTrailingSlashIfPresent(StatusCode redirectionType, Supplier<Route> inner) static RouteredirectToTrailingSlashIfMissing(StatusCode redirectionType, Supplier<Route> inner) static Routereject()static Routestatic Routestatic RouterejectEmptyResponse(Supplier<Route> inner) static <T> Routerequest(Unmarshaller<? super HttpRequest, T> unmarshaller, Function<T, Route> inner) static RouterequestEncodedWith(HttpEncoding encoding, Supplier<Route> inner) static RouterequestEntityEmpty(Supplier<Route> inner) static RouterequestEntityPresent(Supplier<Route> inner) static RouterespondWithDefaultHeader(HttpHeader responseHeader, Supplier<Route> inner) static RouterespondWithDefaultHeaders(Iterable<HttpHeader> responseHeaders, Supplier<Route> inner) static RouterespondWithHeader(HttpHeader responseHeader, Supplier<Route> inner) static RouterespondWithHeaders(Iterable<HttpHeader> responseHeaders, Supplier<Route> inner) static RouteresponseEncodingAccepted(HttpEncoding encoding, Supplier<Route> inner) static Routestatic RouteDeprecated.static Routestatic Routestatic RoutesetCookie(Iterable<HttpCookie> cookies, Supplier<Route> inner) static RoutesetCookie(HttpCookie cookie, Supplier<Route> inner) static RoutestoreUploadedFile(String fieldName, Function<FileInfo, File> destFn, BiFunction<FileInfo, File, Route> inner) static RoutestoreUploadedFiles(String fieldName, Function<FileInfo, File> destFn, Function<List<Map.Entry<FileInfo, File>>, Route> inner) static RoutetoStrictEntity(Duration timeout, long maxBytes, Supplier<Route> inner) static RoutetoStrictEntity(Duration timeout, Supplier<Route> inner) static RoutetoStrictEntity(scala.concurrent.duration.FiniteDuration timeout, long maxBytes, Supplier<Route> inner) static RoutetoStrictEntity(scala.concurrent.duration.FiniteDuration timeout, Supplier<Route> inner) static Routevalidate(BooleanSupplier check, String errorMsg, Supplier<Route> inner) static RoutewithExecutionContext(scala.concurrent.ExecutionContextExecutor ec, Supplier<Route> inner) static Routestatic RoutewithMaterializer(org.apache.pekko.stream.Materializer mat, Supplier<Route> inner) static RouteAdapterwithoutRequestTimeout(Supplier<Route> inner) static RoutewithoutSizeLimit(Supplier<Route> inner) static Routestatic RoutewithRangeSupport(Supplier<Route> inner) static RouteAdapterwithRequestTimeout(Duration timeout, Function<HttpRequest, HttpResponse> timeoutHandler, Supplier<Route> inner) static RouteAdapterwithRequestTimeout(Duration timeout, Supplier<Route> inner) static RouteAdapterwithRequestTimeout(scala.concurrent.duration.Duration timeout, Function<HttpRequest, HttpResponse> timeoutHandler, Supplier<Route> inner) static RouteAdapterwithRequestTimeout(scala.concurrent.duration.Duration timeout, Supplier<Route> inner) static RouteAdapterwithRequestTimeoutResponse(Function<HttpRequest, HttpResponse> timeoutHandler, Supplier<Route> inner) static RoutewithSettings(RoutingSettings s, Supplier<Route> inner) static RoutewithSizeLimit(long maxBytes, Supplier<Route> inner)
-
Constructor Details
-
Directives
public Directives()
-
-
Method Details
-
route
-
getFromBrowseableDirectories
-
route
Deprecated. -
getFromBrowseableDirectories
-
anyOf
public static Route anyOf(Function<Supplier<Route>, Route> first, Function<Supplier<Route>, Route> second, Supplier<Route> inner) Composes two 0-argument directives which share the same inner Route. This is equivalent tofirst(inner).orElse(second(inner))Usage example:anyOf(this::get, this::post, () -> complete("hi")))- Parameters:
first- the first 0-argument directivesecond- the second 0-argument directiveinner- the inner route Producer- Returns:
- the resulting route
-
anyOf
public static <A> Route anyOf(Function<Function<A, Route>, Route> first, Function<Function<A, Route>, Route> second, Function<A, Route> inner) Composes two 1-argument directives (directives whose inner route takes a parameter) which share the same inner route. This is the same asfirst(inner).orElse(second(inner)). This can be used also for directives that take an additional parameter if the directive is partially applied, ie. parameter Usage example:anyOf(bindParameter(this::path, "bar"), bindParameter(this::path, "baz"), () -> complete("bar or baz"))- Parameters:
first- the first 1-argument directivesecond- the second 1-argument directiveinner- the inner route that takes one argument- Returns:
- the resulting route
-
allOf
public static Route allOf(Function<Supplier<Route>, Route> first, Function<Supplier<Route>, Route> second, Supplier<Route> inner) Nests two 0-argument directives together Usage example:allOf(bindParameter(this::pathPrefix, "alice"), bindParameter(this::path, "bob"), () -> complete("Charlie!"))- Parameters:
first- the 0-argument directive (outer one)second- the 0-argument directive (inner one)inner- the inner route function- Returns:
- the resulting route
-
allOf
public static <A,B> Route allOf(Function<Function<A, Route>, Route> first, Function<Function<B, Route>, Route> second, BiFunction<A, B, Route> inner) Nests two 1-argument directives together Usage example:allOf(this::extractScheme, this::extractMethod, (scheme, method) -> complete("You did a " + method.name() + " using " + scheme))- Parameters:
first- the first 1-argument directive (outer one)second- the second 1-argument directive (inner one)inner- the inner route function that takes 2 different parameters- Returns:
- the resulting route
-
allOf
public static <A> Route allOf(Function<Supplier<Route>, Route> first, Function<Function<A, Route>, Route> second, Function<A, Route> inner) Nests one 0-argument and 1-argument directives together Usage example:allOf(bindParameter(this::pathPrefix, "guess"), this::extractMethod, method -> complete("You did a " + method.name()))- Parameters:
first- the 0-argument directive (outer one)second- the 1-argument directive (inner one)inner- the inner route function that takes 1 parameter- Returns:
- the resulting route
-
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<org.apache.pekko.stream.javadsl.Source<org.apache.pekko.util.ByteString, Object>, Route> inner) -
extractRequestEntity
-
extractStrictEntity
public static Route extractStrictEntity(scala.concurrent.duration.FiniteDuration timeout, Function<HttpEntity.Strict, Route> inner) -
extractStrictEntity
-
extractStrictEntity
public static Route extractStrictEntity(scala.concurrent.duration.FiniteDuration timeout, long maxBytes, Function<HttpEntity.Strict, Route> inner) -
extractStrictEntity
public static Route extractStrictEntity(Duration timeout, long maxBytes, Function<HttpEntity.Strict, Route> inner) -
toStrictEntity
-
toStrictEntity
-
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
-
listDirectoryContents
-
listDirectoryContents
public static Route listDirectoryContents(DirectoryRenderer directoryRenderer, scala.collection.immutable.Seq<String> directories) -
defaultDirectoryRenderer
-
defaultContentTypeResolver
-
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(org.apache.pekko.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) -
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(org.apache.pekko.japi.function.Function<HttpRequest, CompletionStage<HttpResponse>> handler) -
handleSync
public static Route handleSync(org.apache.pekko.japi.function.Function<HttpRequest, HttpResponse> handler) -
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(org.apache.pekko.japi.function.Function<RequestContext, Object> check, Supplier<Route> inner) -
authorizeAsync
-
authorizeAsyncWithRequestContext
public static Route authorizeAsyncWithRequestContext(org.apache.pekko.japi.function.Function<RequestContext, CompletionStage<Object>> check, Supplier<Route> inner) -
extractWebSocketUpgrade
-
extractOfferedWsProtocols
-
handleWebSocketMessages
-
handleWebSocketMessagesForProtocol
-
handleWebSocketMessagesForOptionalProtocol
-
extractRequestTimeout
-
withRequestTimeout
public static RouteAdapter withRequestTimeout(scala.concurrent.duration.Duration timeout, Supplier<Route> inner) -
withRequestTimeout
-
withRequestTimeout
public static RouteAdapter withRequestTimeout(scala.concurrent.duration.Duration timeout, Function<HttpRequest, HttpResponse> timeoutHandler, Supplier<Route> inner) -
withRequestTimeout
public static RouteAdapter withRequestTimeout(Duration timeout, Function<HttpRequest, HttpResponse> timeoutHandler, Supplier<Route> inner) -
withoutRequestTimeout
-
withRequestTimeoutResponse
public static RouteAdapter withRequestTimeoutResponse(Function<HttpRequest, HttpResponse> timeoutHandler, Supplier<Route> inner) -
entityAsSourceOf
public static <T> Route entityAsSourceOf(Unmarshaller<org.apache.pekko.util.ByteString, T> um, EntityStreamingSupport support, Function<org.apache.pekko.stream.javadsl.Source<T, org.apache.pekko.NotUsed>, Route> inner) -
completeWithSource
public static <T,M> Route completeWithSource(org.apache.pekko.stream.javadsl.Source<T, M> source, Marshaller<T, org.apache.pekko.util.ByteString> m, EntityStreamingSupport support) -
completeOKWithSource
public static <T,M> Route completeOKWithSource(org.apache.pekko.stream.javadsl.Source<T, M> source, Marshaller<T, RequestEntity> m, EntityStreamingSupport support)
-