public class Directives
extends java.lang.Object
See pekko.http.scaladsl.server.Directives
for ScalaDSL equivalent of this class.
Constructor and Description |
---|
Directives() |
Modifier and Type | Method and Description |
---|---|
static <A,B> Route |
allOf(java.util.function.Function<java.util.function.Function<A,Route>,Route> first,
java.util.function.Function<java.util.function.Function<B,Route>,Route> second,
java.util.function.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> Route |
allOf(java.util.function.Function<java.util.function.Supplier<Route>,Route> first,
java.util.function.Function<java.util.function.Function<A,Route>,Route> second,
java.util.function.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 Route |
allOf(java.util.function.Function<java.util.function.Supplier<Route>,Route> first,
java.util.function.Function<java.util.function.Supplier<Route>,Route> second,
java.util.function.Supplier<Route> inner)
Nests two 0-argument directives together
Usage example:
allOf(bindParameter(this::pathPrefix, "alice"), bindParameter(this::path, "bob"), () -> complete("Charlie!")) |
static <A> Route |
anyOf(java.util.function.Function<java.util.function.Function<A,Route>,Route> first,
java.util.function.Function<java.util.function.Function<A,Route>,Route> second,
java.util.function.Function<A,Route> inner)
Composes two 1-argument directives (directives whose inner route takes a parameter) which share the same inner route.
|
static Route |
anyOf(java.util.function.Function<java.util.function.Supplier<Route>,Route> first,
java.util.function.Function<java.util.function.Supplier<Route>,Route> second,
java.util.function.Supplier<Route> inner)
Composes two 0-argument directives which share the same inner Route.
|
static <T> RouteAdapter |
attribute(AttributeKey<T> key,
java.util.function.Function<T,Route> inner) |
static <T> Route |
authenticateBasic(java.lang.String realm,
java.util.function.Function<java.util.Optional<SecurityDirectives.ProvidedCredentials>,java.util.Optional<T>> authenticator,
java.util.function.Function<T,Route> inner) |
static <T> Route |
authenticateBasicAsync(java.lang.String realm,
java.util.function.Function<java.util.Optional<SecurityDirectives.ProvidedCredentials>,java.util.concurrent.CompletionStage<java.util.Optional<T>>> authenticator,
java.util.function.Function<T,Route> inner) |
static <T> Route |
authenticateBasicAsyncOptional(java.lang.String realm,
java.util.function.Function<java.util.Optional<SecurityDirectives.ProvidedCredentials>,java.util.concurrent.CompletionStage<java.util.Optional<T>>> authenticator,
java.util.function.Function<java.util.Optional<T>,Route> inner) |
static <T> Route |
authenticateBasicOptional(java.lang.String realm,
java.util.function.Function<java.util.Optional<SecurityDirectives.ProvidedCredentials>,java.util.Optional<T>> authenticator,
java.util.function.Function<java.util.Optional<T>,Route> inner) |
static <T> Route |
authenticateBasicPF(java.lang.String realm,
scala.PartialFunction<java.util.Optional<SecurityDirectives.ProvidedCredentials>,T> authenticator,
java.util.function.Function<T,Route> inner) |
static <T> Route |
authenticateBasicPFAsync(java.lang.String realm,
scala.PartialFunction<java.util.Optional<SecurityDirectives.ProvidedCredentials>,java.util.concurrent.CompletionStage<T>> authenticator,
java.util.function.Function<T,Route> inner) |
static <T> Route |
authenticateOAuth2(java.lang.String realm,
java.util.function.Function<java.util.Optional<SecurityDirectives.ProvidedCredentials>,java.util.Optional<T>> authenticator,
java.util.function.Function<T,Route> inner) |
static <T> Route |
authenticateOAuth2Async(java.lang.String realm,
java.util.function.Function<java.util.Optional<SecurityDirectives.ProvidedCredentials>,java.util.concurrent.CompletionStage<java.util.Optional<T>>> authenticator,
java.util.function.Function<T,Route> inner) |
static <T> Route |
authenticateOAuth2AsyncOptional(java.lang.String realm,
java.util.function.Function<java.util.Optional<SecurityDirectives.ProvidedCredentials>,java.util.concurrent.CompletionStage<java.util.Optional<T>>> authenticator,
java.util.function.Function<java.util.Optional<T>,Route> inner) |
static <T> Route |
authenticateOAuth2Optional(java.lang.String realm,
java.util.function.Function<java.util.Optional<SecurityDirectives.ProvidedCredentials>,java.util.Optional<T>> authenticator,
java.util.function.Function<java.util.Optional<T>,Route> inner) |
static <C extends HttpCredentials,T> |
authenticateOrRejectWithChallenge(java.lang.Class<C> c,
java.util.function.Function<java.util.Optional<C>,java.util.concurrent.CompletionStage<scala.util.Either<HttpChallenge,T>>> authenticator,
java.util.function.Function<T,Route> inner) |
static <T> Route |
authenticateOrRejectWithChallenge(java.util.function.Function<java.util.Optional<HttpCredentials>,java.util.concurrent.CompletionStage<scala.util.Either<HttpChallenge,T>>> authenticator,
java.util.function.Function<T,Route> inner) |
static Route |
authorize(java.util.function.Supplier<java.lang.Object> check,
java.util.function.Supplier<Route> inner) |
static Route |
authorizeAsync(java.util.function.Supplier<java.util.concurrent.CompletionStage<java.lang.Object>> check,
java.util.function.Supplier<Route> inner) |
static Route |
authorizeAsyncWithRequestContext(org.apache.pekko.japi.function.Function<RequestContext,java.util.concurrent.CompletionStage<java.lang.Object>> check,
java.util.function.Supplier<Route> inner) |
static Route |
authorizeWithRequestContext(org.apache.pekko.japi.function.Function<RequestContext,java.lang.Object> check,
java.util.function.Supplier<Route> inner) |
static Route |
cancelRejection(Rejection rejection,
java.util.function.Supplier<Route> inner) |
static Route |
cancelRejections(java.lang.Iterable<java.lang.Class<?>> classes,
java.util.function.Supplier<Route> inner) |
static Route |
cancelRejections(java.util.function.Predicate<Rejection> filter,
java.util.function.Supplier<Route> inner) |
static Route |
checkSameOrigin(HttpOriginRange allowed,
java.util.function.Supplier<Route> inner) |
static Route |
complete(HttpResponse response) |
static RouteAdapter |
complete(java.lang.Iterable<HttpHeader> headers,
RequestEntity entity) |
static RouteAdapter |
complete(java.lang.Iterable<HttpHeader> headers,
ResponseEntity entity) |
static <T> RouteAdapter |
complete(java.lang.Iterable<HttpHeader> headers,
T value,
Marshaller<T,RequestEntity> marshaller) |
static RouteAdapter |
complete(RequestEntity entity) |
static RouteAdapter |
complete(ResponseEntity entity) |
static Route |
complete(StatusCode status) |
static RouteAdapter |
complete(StatusCode status,
java.lang.Iterable<HttpHeader> headers,
RequestEntity entity) |
static RouteAdapter |
complete(StatusCode status,
java.lang.Iterable<HttpHeader> headers,
ResponseEntity entity) |
static <T> RouteAdapter |
complete(StatusCode status,
java.lang.Iterable<HttpHeader> headers,
T value,
Marshaller<T,RequestEntity> marshaller) |
static RouteAdapter |
complete(StatusCode status,
RequestEntity entity) |
static RouteAdapter |
complete(StatusCode status,
ResponseEntity entity) |
static RouteAdapter |
complete(StatusCode status,
java.lang.String entity) |
static <T> RouteAdapter |
complete(StatusCode status,
T value,
Marshaller<T,RequestEntity> marshaller) |
static Route |
complete(java.lang.String body) |
static <T> RouteAdapter |
complete(T value,
Marshaller<T,HttpResponse> marshaller) |
static <T> RouteAdapter |
completeOK(T value,
Marshaller<T,RequestEntity> marshaller) |
static RouteAdapter |
completeOKWithFuture(java.util.concurrent.CompletionStage<RequestEntity> value) |
static <T> RouteAdapter |
completeOKWithFuture(java.util.concurrent.CompletionStage<T> value,
Marshaller<T,RequestEntity> marshaller) |
static <T> RouteAdapter |
completeOKWithFuture(scala.concurrent.Future<T> value,
Marshaller<T,RequestEntity> marshaller) |
static RouteAdapter |
completeOKWithFutureString(java.util.concurrent.CompletionStage<java.lang.String> value) |
static RouteAdapter |
completeOKWithFutureString(scala.concurrent.Future<java.lang.String> value) |
static <T,M> Route |
completeOKWithSource(org.apache.pekko.stream.javadsl.Source<T,M> source,
Marshaller<T,RequestEntity> m,
EntityStreamingSupport support) |
static <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) |
static <T> Route |
completeWith(Marshaller<T,? extends HttpResponse> marshaller,
java.util.function.Consumer<java.util.function.Consumer<T>> inner) |
static RouteAdapter |
completeWithFuture(java.util.concurrent.CompletionStage<HttpResponse> value) |
static <T> RouteAdapter |
completeWithFuture(java.util.concurrent.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 |
completeWithFutureStatus(java.util.concurrent.CompletionStage<StatusCode> status) |
static Route |
completeWithFutureStatus(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 Route |
concat(Route first,
Route... alternatives) |
static Route |
concat(Route first,
scala.collection.immutable.Seq<Route> alternatives) |
static Route |
conditional(DateTime lastModified,
java.util.function.Supplier<Route> inner) |
static Route |
conditional(EntityTag eTag,
DateTime lastModified,
java.util.function.Supplier<Route> inner) |
static Route |
conditional(EntityTag eTag,
java.util.function.Supplier<Route> inner) |
static Route |
conditional(java.util.Optional<EntityTag> eTag,
java.util.Optional<DateTime> lastModified,
java.util.function.Supplier<Route> inner) |
static Route |
cookie(java.lang.String name,
java.util.function.Function<HttpCookiePair,Route> inner) |
static Route |
decodeRequest(java.util.function.Supplier<Route> inner) |
static Route |
decodeRequestWith(Coder coder,
java.util.function.Supplier<Route> inner) |
static Route |
decodeRequestWith(java.lang.Iterable<Coder> coders,
java.util.function.Supplier<Route> inner) |
static ContentTypeResolver |
defaultContentTypeResolver() |
static DirectoryRenderer |
defaultDirectoryRenderer() |
static Route |
delete(java.util.function.Supplier<Route> inner) |
static Route |
deleteCookie(HttpCookie cookie,
java.util.function.Supplier<Route> inner) |
static Route |
deleteCookie(java.lang.Iterable<HttpCookie> cookies,
java.util.function.Supplier<Route> inner) |
static Route |
deleteCookie(java.lang.String name,
java.lang.String domain,
java.lang.String path,
java.util.function.Supplier<Route> inner) |
static Route |
deleteCookie(java.lang.String name,
java.lang.String domain,
java.util.function.Supplier<Route> inner) |
static Route |
deleteCookie(java.lang.String name,
java.util.function.Supplier<Route> inner) |
static Route |
encodeResponse(java.util.function.Supplier<Route> inner) |
static Route |
encodeResponseWith(java.lang.Iterable<Coder> coders,
java.util.function.Supplier<Route> inner) |
static <T> Route |
entity(Unmarshaller<? super HttpEntity,T> unmarshaller,
java.util.function.Function<T,Route> inner) |
static <T> Route |
entityAsSourceOf(Unmarshaller<org.apache.pekko.util.ByteString,T> um,
EntityStreamingSupport support,
java.util.function.Function<org.apache.pekko.stream.javadsl.Source<T,org.apache.pekko.NotUsed>,Route> inner) |
static <T> Route |
extract(java.util.function.Function<RequestContext,T> extract,
java.util.function.Function<T,Route> inner) |
static Route |
extractActorSystem(java.util.function.Function<org.apache.pekko.actor.ActorSystem,Route> inner) |
static Route |
extractClientIP(java.util.function.Function<RemoteAddress,Route> inner) |
static Route |
extractCredentials(java.util.function.Function<java.util.Optional<HttpCredentials>,Route> inner) |
static RouteAdapter |
extractDataBytes(java.util.function.Function<org.apache.pekko.stream.javadsl.Source<org.apache.pekko.util.ByteString,java.lang.Object>,Route> inner) |
static Route |
extractEntity(java.util.function.Function<RequestEntity,Route> inner) |
static Route |
extractExecutionContext(java.util.function.Function<scala.concurrent.ExecutionContextExecutor,Route> inner) |
static Route |
extractHost(java.util.function.Function<java.lang.String,Route> inner) |
static Route |
extractLog(java.util.function.Function<org.apache.pekko.event.LoggingAdapter,Route> inner) |
static RouteAdapter |
extractMatchedPath(java.util.function.Function<java.lang.String,Route> inner) |
static Route |
extractMaterializer(java.util.function.Function<org.apache.pekko.stream.Materializer,Route> inner) |
static RouteAdapter |
extractMethod(java.util.function.Function<HttpMethod,Route> inner) |
static Route |
extractOfferedWsProtocols(java.util.function.Function<java.util.List<java.lang.String>,Route> inner) |
static RouteAdapter |
extractParserSettings(java.util.function.Function<ParserSettings,Route> inner) |
static RouteAdapter |
extractRequest(java.util.function.Function<HttpRequest,Route> inner) |
static RouteAdapter |
extractRequestContext(java.util.function.Function<RequestContext,Route> inner) |
static Route |
extractRequestEntity(java.util.function.Function<RequestEntity,Route> inner) |
static RouteAdapter |
extractRequestTimeout(java.util.function.Function<scala.concurrent.duration.Duration,Route> inner) |
static Route |
extractScheme(java.util.function.Function<java.lang.String,Route> inner) |
static RouteAdapter |
extractSettings(java.util.function.Function<RoutingSettings,Route> inner) |
static Route |
extractStrictEntity(scala.concurrent.duration.FiniteDuration timeout,
java.util.function.Function<HttpEntity.Strict,Route> inner) |
static Route |
extractStrictEntity(scala.concurrent.duration.FiniteDuration timeout,
long maxBytes,
java.util.function.Function<HttpEntity.Strict,Route> inner) |
static RouteAdapter |
extractUnmatchedPath(java.util.function.Function<java.lang.String,Route> inner) |
static Route |
extractUpgradeToWebSocket(java.util.function.Function<UpgradeToWebSocket,Route> inner) |
static RouteAdapter |
extractUri(java.util.function.Function<Uri,Route> inner) |
static Route |
extractWebSocketUpgrade(java.util.function.Function<WebSocketUpgrade,Route> inner) |
static Route |
failWith(java.lang.Throwable error) |
static Route |
fileUpload(java.lang.String fieldName,
java.util.function.BiFunction<FileInfo,org.apache.pekko.stream.javadsl.Source<org.apache.pekko.util.ByteString,java.lang.Object>,Route> inner) |
static Route |
fileUploadAll(java.lang.String fieldName,
java.util.function.Function<java.util.List<java.util.Map.Entry<FileInfo,org.apache.pekko.stream.javadsl.Source<org.apache.pekko.util.ByteString,java.lang.Object>>>,Route> inner) |
static Route |
formField(java.lang.String name,
java.util.function.Function<java.lang.String,Route> inner) |
static <T> Route |
formField(Unmarshaller<java.lang.String,T> t,
java.lang.String name,
java.util.function.Function<T,Route> inner) |
static Route |
formFieldList(java.util.function.Function<java.util.List<java.util.Map.Entry<java.lang.String,java.lang.String>>,Route> inner) |
static Route |
formFieldList(java.lang.String name,
java.util.function.Function<java.util.List<java.lang.String>,Route> inner) |
static <T> Route |
formFieldList(Unmarshaller<java.lang.String,T> t,
java.lang.String name,
java.util.function.Function<java.util.List<T>,Route> inner) |
static Route |
formFieldMap(java.util.function.Function<java.util.Map<java.lang.String,java.lang.String>,Route> inner) |
static Route |
formFieldMultiMap(java.util.function.Function<java.util.Map<java.lang.String,java.util.List<java.lang.String>>,Route> inner) |
static Route |
formFieldOptional(java.lang.String name,
java.util.function.Function<java.util.Optional<java.lang.String>,Route> inner) |
static <T> Route |
formFieldOptional(Unmarshaller<java.lang.String,T> t,
java.lang.String name,
java.util.function.Function<java.util.Optional<T>,Route> inner) |
static Route |
get(java.util.function.Supplier<Route> inner) |
static Route |
getFromBrowseableDirectories(scala.collection.immutable.Seq<java.lang.String> directories) |
static Route |
getFromBrowseableDirectories(java.lang.String... directories) |
static Route |
getFromBrowseableDirectory(java.lang.String directory) |
static Route |
getFromBrowseableDirectory(java.lang.String directory,
ContentTypeResolver resolver) |
static Route |
getFromBrowseableDirectory(java.lang.String directory,
DirectoryRenderer renderer) |
static Route |
getFromBrowseableDirectory(java.lang.String directory,
DirectoryRenderer renderer,
ContentTypeResolver resolver) |
static Route |
getFromDirectory(java.lang.String directoryPath) |
static Route |
getFromDirectory(java.lang.String directoryPath,
ContentTypeResolver resolver) |
static Route |
getFromFile(java.io.File file) |
static Route |
getFromFile(java.io.File file,
ContentType contentType) |
static Route |
getFromFile(java.io.File file,
ContentTypeResolver resolver) |
static Route |
getFromFile(java.lang.String file) |
static Route |
getFromFile(java.lang.String file,
ContentTypeResolver resolver) |
static Route |
getFromResource(java.lang.String path) |
static Route |
getFromResource(java.lang.String path,
ContentType contentType) |
static Route |
getFromResource(java.lang.String path,
ContentType contentType,
java.lang.ClassLoader classLoader) |
static Route |
getFromResource(java.lang.String path,
ContentTypeResolver resolver) |
static Route |
getFromResourceDirectory(java.lang.String directoryName) |
static Route |
getFromResourceDirectory(java.lang.String directoryName,
java.lang.ClassLoader classLoader) |
static Route |
getFromResourceDirectory(java.lang.String directoryName,
ContentTypeResolver resolver) |
static Route |
getFromResourceDirectory(java.lang.String directoryName,
ContentTypeResolver resolver,
java.lang.ClassLoader classLoader) |
static Route |
handle(org.apache.pekko.japi.function.Function<HttpRequest,java.util.concurrent.CompletionStage<HttpResponse>> handler) |
static RouteAdapter |
handleExceptions(ExceptionHandler handler,
java.util.function.Supplier<Route> inner) |
static RouteAdapter |
handleRejections(RejectionHandler handler,
java.util.function.Supplier<Route> inner) |
static Route |
handleSync(org.apache.pekko.japi.function.Function<HttpRequest,HttpResponse> handler) |
static <T> Route |
handleWebSocketMessages(org.apache.pekko.stream.javadsl.Flow<Message,Message,T> handler) |
static <T> Route |
handleWebSocketMessagesForOptionalProtocol(org.apache.pekko.stream.javadsl.Flow<Message,Message,T> handler,
java.util.Optional<java.lang.String> subprotocol) |
static <T> Route |
handleWebSocketMessagesForProtocol(org.apache.pekko.stream.javadsl.Flow<Message,Message,T> handler,
java.lang.String subprotocol) |
static <T,R> Route |
handleWith(Unmarshaller<? super HttpEntity,T> unmarshaller,
Marshaller<R,? extends HttpResponse> marshaller,
java.util.function.Function<T,R> inner) |
static Route |
head(java.util.function.Supplier<Route> inner) |
static <T> RouteAdapter |
headerValue(java.util.function.Function<HttpHeader,java.util.Optional<T>> f,
java.util.function.Function<T,Route> inner) |
static RouteAdapter |
headerValueByName(java.lang.String headerName,
java.util.function.Function<java.lang.String,Route> inner) |
static <T extends HttpHeader> |
headerValueByType(java.lang.Class<T> t,
java.util.function.Function<T,Route> inner) |
static <T> RouteAdapter |
headerValuePF(scala.PartialFunction<HttpHeader,T> pf,
java.util.function.Function<T,Route> inner) |
static Route |
host(java.lang.Iterable<java.lang.String> hostNames,
java.util.function.Supplier<Route> inner) |
static Route |
host(java.util.regex.Pattern regex,
java.util.function.Function<java.lang.String,Route> inner) |
static Route |
host(java.util.function.Predicate<java.lang.String> predicate,
java.util.function.Supplier<Route> inner) |
static Route |
host(java.lang.String hostName,
java.util.function.Supplier<Route> inner) |
static Route |
ignoreTrailingSlash(java.util.function.Supplier<Route> inner) |
static Route |
listDirectoryContents(DirectoryRenderer directoryRenderer,
scala.collection.immutable.Seq<java.lang.String> directories) |
static Route |
listDirectoryContents(DirectoryRenderer directoryRenderer,
java.lang.String... directories) |
static Route |
listDirectoryContents(scala.collection.immutable.Seq<java.lang.String> directories) |
static Route |
listDirectoryContents(java.lang.String... directories) |
static Route |
logRequest(java.util.function.Function<HttpRequest,LogEntry> show,
java.util.function.Supplier<Route> inner) |
static Route |
logRequest(java.lang.String marker,
org.apache.pekko.event.Logging.LogLevel level,
java.util.function.Supplier<Route> inner) |
static Route |
logRequest(java.lang.String marker,
java.util.function.Supplier<Route> inner) |
static RouteAdapter |
logRequestResult(java.util.function.BiFunction<HttpRequest,HttpResponse,LogEntry> showSuccess,
java.util.function.BiFunction<HttpRequest,java.util.List<Rejection>,LogEntry> showRejection,
java.util.function.Supplier<Route> inner) |
static RouteAdapter |
logRequestResultOptional(java.util.function.BiFunction<HttpRequest,HttpResponse,java.util.Optional<LogEntry>> showSuccess,
java.util.function.BiFunction<HttpRequest,java.util.List<Rejection>,java.util.Optional<LogEntry>> showRejection,
java.util.function.Supplier<Route> inner) |
static RouteAdapter |
logResult(java.util.function.Function<HttpResponse,LogEntry> showSuccess,
java.util.function.Function<java.util.List<Rejection>,LogEntry> showRejection,
java.util.function.Supplier<Route> inner) |
static Route |
logResult(java.lang.String marker,
org.apache.pekko.event.Logging.LogLevel level,
java.util.function.Supplier<Route> inner) |
static Route |
logResult(java.lang.String marker,
java.util.function.Supplier<Route> inner) |
static Route |
mapInnerRoute(java.util.function.Function<Route,Route> f,
java.util.function.Supplier<Route> inner) |
static Route |
mapRejections(java.util.function.Function<java.util.List<Rejection>,java.util.List<Rejection>> f,
java.util.function.Supplier<Route> inner) |
static Route |
mapRequest(java.util.function.Function<HttpRequest,HttpRequest> f,
java.util.function.Supplier<Route> inner) |
static Route |
mapRequestContext(java.util.function.Function<RequestContext,RequestContext> f,
java.util.function.Supplier<Route> inner) |
static Route |
mapResponse(java.util.function.Function<HttpResponse,HttpResponse> f,
java.util.function.Supplier<Route> inner) |
static Route |
mapResponseEntity(java.util.function.Function<ResponseEntity,ResponseEntity> f,
java.util.function.Supplier<Route> inner) |
static Route |
mapResponseHeaders(java.util.function.Function<java.util.List<HttpHeader>,java.util.List<HttpHeader>> f,
java.util.function.Supplier<Route> inner) |
static Route |
mapRouteResult(java.util.function.Function<RouteResult,RouteResult> f,
java.util.function.Supplier<Route> inner) |
static Route |
mapRouteResultFuture(java.util.function.Function<java.util.concurrent.CompletionStage<RouteResult>,java.util.concurrent.CompletionStage<RouteResult>> f,
java.util.function.Supplier<Route> inner) |
static Route |
mapRouteResultPF(scala.PartialFunction<RouteResult,RouteResult> f,
java.util.function.Supplier<Route> inner) |
static Route |
mapRouteResultWith(java.util.function.Function<RouteResult,java.util.concurrent.CompletionStage<RouteResult>> f,
java.util.function.Supplier<Route> inner) |
static Route |
mapRouteResultWithPF(scala.PartialFunction<RouteResult,java.util.concurrent.CompletionStage<RouteResult>> f,
java.util.function.Supplier<Route> inner) |
static Route |
mapSettings(java.util.function.Function<RoutingSettings,RoutingSettings> f,
java.util.function.Supplier<Route> inner) |
static Route |
mapUnmatchedPath(java.util.function.Function<java.lang.String,java.lang.String> f,
java.util.function.Supplier<Route> inner) |
static Route |
method(HttpMethod method,
java.util.function.Supplier<Route> inner) |
static <T> RouteAdapter |
onComplete(java.util.concurrent.CompletionStage<T> cs,
java.util.function.Function<scala.util.Try<T>,Route> inner) |
static <T> RouteAdapter |
onComplete(java.util.function.Supplier<java.util.concurrent.CompletionStage<T>> f,
java.util.function.Function<scala.util.Try<T>,Route> inner) |
static <T> RouteAdapter |
onCompleteWithBreaker(org.apache.pekko.pattern.CircuitBreaker breaker,
java.util.function.Supplier<java.util.concurrent.CompletionStage<T>> f,
java.util.function.Function<scala.util.Try<T>,Route> inner) |
static <T> RouteAdapter |
onSuccess(java.util.concurrent.CompletionStage<T> cs,
java.util.function.Function<T,Route> inner) |
static <T> RouteAdapter |
onSuccess(java.util.function.Supplier<java.util.concurrent.CompletionStage<T>> f,
java.util.function.Function<T,Route> inner) |
static <T> RouteAdapter |
optionalAttribute(AttributeKey<T> key,
java.util.function.Function<java.util.Optional<T>,Route> inner) |
static Route |
optionalCookie(java.lang.String name,
java.util.function.Function<java.util.Optional<HttpCookiePair>,Route> inner) |
static <T> RouteAdapter |
optionalHeaderValue(java.util.function.Function<HttpHeader,java.util.Optional<T>> f,
java.util.function.Function<java.util.Optional<T>,Route> inner) |
static RouteAdapter |
optionalHeaderValueByName(java.lang.String headerName,
java.util.function.Function<java.util.Optional<java.lang.String>,Route> inner) |
static <T extends HttpHeader> |
optionalHeaderValueByType(java.lang.Class<T> t,
java.util.function.Function<java.util.Optional<T>,Route> inner) |
static <T> RouteAdapter |
optionalHeaderValuePF(scala.PartialFunction<HttpHeader,T> pf,
java.util.function.Function<java.util.Optional<T>,Route> inner) |
static Route |
options(java.util.function.Supplier<Route> inner) |
static Route |
overrideMethodWithParameter(java.lang.String paramName,
java.util.function.Supplier<Route> inner) |
static Route |
parameter(java.lang.String name,
java.util.function.Function<java.lang.String,Route> inner) |
static <T> Route |
parameter(Unmarshaller<java.lang.String,T> t,
java.lang.String name,
java.util.function.Function<T,Route> inner) |
static Route |
parameterList(java.util.function.Function<java.util.List<java.util.Map.Entry<java.lang.String,java.lang.String>>,Route> inner) |
static Route |
parameterList(java.lang.String name,
java.util.function.Function<java.util.List<java.lang.String>,Route> inner) |
static <T> Route |
parameterList(Unmarshaller<java.lang.String,T> t,
java.lang.String name,
java.util.function.Function<java.util.List<T>,Route> inner) |
static Route |
parameterMap(java.util.function.Function<java.util.Map<java.lang.String,java.lang.String>,Route> inner) |
static Route |
parameterMultiMap(java.util.function.Function<java.util.Map<java.lang.String,java.util.List<java.lang.String>>,Route> inner) |
static Route |
parameterOptional(java.lang.String name,
java.util.function.Function<java.util.Optional<java.lang.String>,Route> inner) |
static <T> Route |
parameterOptional(Unmarshaller<java.lang.String,T> t,
java.lang.String name,
java.util.function.Function<java.util.Optional<T>,Route> inner) |
static <T> Route |
parameterOrDefault(Unmarshaller<java.lang.String,T> t,
T defaultValue,
java.lang.String name,
java.util.function.Function<T,Route> inner) |
static <T> Route |
parameterRequiredValue(Unmarshaller<java.lang.String,T> t,
T requiredValue,
java.lang.String name,
java.util.function.Supplier<Route> inner) |
static Route |
pass(java.util.function.Supplier<Route> inner) |
static Route |
patch(java.util.function.Supplier<Route> inner) |
static Route |
path(java.util.function.Function<java.lang.String,Route> inner) |
static Route |
path(PathMatcher0 p,
java.util.function.Supplier<Route> inner) |
static <T> Route |
path(PathMatcher1<T> p,
java.util.function.Function<T,Route> inner) |
static <T1,T2> Route |
path(PathMatcher2<T1,T2> p,
java.util.function.BiFunction<T1,T2,Route> inner) |
static Route |
path(java.lang.String segment,
java.util.function.Supplier<Route> inner) |
static <T> Route |
path(Unmarshaller<java.lang.String,T> t,
java.util.function.Function<T,Route> inner) |
static Route |
pathEnd(java.util.function.Supplier<Route> inner) |
static Route |
pathEndOrSingleSlash(java.util.function.Supplier<Route> inner) |
static Route |
pathPrefix(java.util.function.Function<java.lang.String,Route> inner) |
static Route |
pathPrefix(PathMatcher0 p,
java.util.function.Supplier<Route> inner) |
static <T> Route |
pathPrefix(PathMatcher1<T> p,
java.util.function.Function<T,Route> inner) |
static <T1,T2> Route |
pathPrefix(PathMatcher2<T1,T2> p,
java.util.function.BiFunction<T1,T2,Route> inner) |
static Route |
pathPrefix(java.lang.String segment,
java.util.function.Supplier<Route> inner) |
static <T> Route |
pathPrefix(Unmarshaller<java.lang.String,T> t,
java.util.function.Function<T,Route> inner) |
static Route |
pathPrefixTest(PathMatcher0 pm,
java.util.function.Supplier<Route> inner) |
static <T1> Route |
pathPrefixTest(PathMatcher1<T1> pm,
java.util.function.Function<T1,Route> inner) |
static <T1,T2> Route |
pathPrefixTest(PathMatcher2<T1,T2> pm,
java.util.function.BiFunction<T1,T2,Route> inner) |
static Route |
pathPrefixTest(java.lang.String segment,
java.util.function.Supplier<Route> inner) |
static Route |
pathSingleSlash(java.util.function.Supplier<Route> inner) |
static Route |
pathSuffix(PathMatcher0 pm,
java.util.function.Supplier<Route> inner) |
static <T1> Route |
pathSuffix(PathMatcher1<T1> pm,
java.util.function.Function<T1,Route> inner) |
static <T1,T2> Route |
pathSuffix(PathMatcher2<T1,T2> pm,
java.util.function.BiFunction<T1,T2,Route> inner) |
static Route |
pathSuffix(java.lang.String segment,
java.util.function.Supplier<Route> inner) |
static Route |
pathSuffixTest(PathMatcher0 pm,
java.util.function.Supplier<Route> inner) |
static <T1> Route |
pathSuffixTest(PathMatcher1<T1> pm,
java.util.function.Function<T1,Route> inner) |
static <T1,T2> Route |
pathSuffixTest(PathMatcher2<T1,T2> pm,
java.util.function.BiFunction<T1,T2,Route> inner) |
static Route |
pathSuffixTest(java.lang.String segment,
java.util.function.Supplier<Route> inner) |
static Route |
post(java.util.function.Supplier<Route> inner) |
static <T> Route |
provide(T t,
java.util.function.Function<T,Route> inner) |
static Route |
put(java.util.function.Supplier<Route> inner) |
static Route |
rawPathPrefix(PathMatcher0 pm,
java.util.function.Supplier<Route> inner) |
static <T1> Route |
rawPathPrefix(PathMatcher1<T1> pm,
java.util.function.Function<T1,Route> inner) |
static <T1,T2> Route |
rawPathPrefix(PathMatcher2<T1,T2> pm,
java.util.function.BiFunction<T1,T2,Route> inner) |
static Route |
rawPathPrefix(java.lang.String segment,
java.util.function.Supplier<Route> inner) |
static Route |
rawPathPrefixTest(PathMatcher0 pm,
java.util.function.Supplier<Route> inner) |
static <T1> Route |
rawPathPrefixTest(PathMatcher1<T1> pm,
java.util.function.Function<T1,Route> inner) |
static <T1,T2> Route |
rawPathPrefixTest(PathMatcher2<T1,T2> pm,
java.util.function.BiFunction<T1,T2,Route> inner) |
static Route |
rawPathPrefixTest(java.lang.String segment,
java.util.function.Supplier<Route> inner) |
static Route |
recoverRejections(java.util.function.Function<java.lang.Iterable<Rejection>,RouteResult> f,
java.util.function.Supplier<Route> inner) |
static Route |
recoverRejectionsWith(java.util.function.Function<java.lang.Iterable<Rejection>,java.util.concurrent.CompletionStage<RouteResult>> f,
java.util.function.Supplier<Route> inner) |
static Route |
redirect(Uri uri,
StatusCode redirectionType) |
static Route |
redirectToNoTrailingSlashIfPresent(StatusCode redirectionType,
java.util.function.Supplier<Route> inner) |
static Route |
redirectToTrailingSlashIfMissing(StatusCode redirectionType,
java.util.function.Supplier<Route> inner) |
static Route |
reject() |
static Route |
reject(Rejection rejection,
Rejection... rejections) |
static Route |
reject(Rejection rejection,
scala.collection.immutable.Seq<Rejection> rejections) |
static Route |
rejectEmptyResponse(java.util.function.Supplier<Route> inner) |
static <T> Route |
request(Unmarshaller<? super HttpRequest,T> unmarshaller,
java.util.function.Function<T,Route> inner) |
static Route |
requestEncodedWith(HttpEncoding encoding,
java.util.function.Supplier<Route> inner) |
static Route |
requestEntityEmpty(java.util.function.Supplier<Route> inner) |
static Route |
requestEntityPresent(java.util.function.Supplier<Route> inner) |
static Route |
respondWithDefaultHeader(HttpHeader responseHeader,
java.util.function.Supplier<Route> inner) |
static Route |
respondWithDefaultHeaders(java.lang.Iterable<HttpHeader> responseHeaders,
java.util.function.Supplier<Route> inner) |
static Route |
respondWithHeader(HttpHeader responseHeader,
java.util.function.Supplier<Route> inner) |
static Route |
respondWithHeaders(java.lang.Iterable<HttpHeader> responseHeaders,
java.util.function.Supplier<Route> inner) |
static Route |
responseEncodingAccepted(HttpEncoding encoding,
java.util.function.Supplier<Route> inner) |
static Route |
route(Route... alternatives) |
static Route |
route(scala.collection.immutable.Seq<Route> alternatives)
Deprecated.
|
static Route |
scheme(java.lang.String name,
java.util.function.Supplier<Route> inner) |
static Route |
selectPreferredLanguage(java.lang.Iterable<Language> languages,
java.util.function.Function<Language,Route> inner) |
static Route |
setCookie(HttpCookie cookie,
java.util.function.Supplier<Route> inner) |
static Route |
setCookie(java.lang.Iterable<HttpCookie> cookies,
java.util.function.Supplier<Route> inner) |
static Route |
storeUploadedFile(java.lang.String fieldName,
java.util.function.Function<FileInfo,java.io.File> destFn,
java.util.function.BiFunction<FileInfo,java.io.File,Route> inner) |
static Route |
storeUploadedFiles(java.lang.String fieldName,
java.util.function.Function<FileInfo,java.io.File> destFn,
java.util.function.Function<java.util.List<java.util.Map.Entry<FileInfo,java.io.File>>,Route> inner) |
static Route |
toStrictEntity(scala.concurrent.duration.FiniteDuration timeout,
long maxBytes,
java.util.function.Supplier<Route> inner) |
static Route |
toStrictEntity(scala.concurrent.duration.FiniteDuration timeout,
java.util.function.Supplier<Route> inner) |
static Route |
validate(java.util.function.BooleanSupplier check,
java.lang.String errorMsg,
java.util.function.Supplier<Route> inner) |
static Route |
withExecutionContext(scala.concurrent.ExecutionContextExecutor ec,
java.util.function.Supplier<Route> inner) |
static Route |
withLog(org.apache.pekko.event.LoggingAdapter log,
java.util.function.Supplier<Route> inner) |
static Route |
withMaterializer(org.apache.pekko.stream.Materializer mat,
java.util.function.Supplier<Route> inner) |
static RouteAdapter |
withoutRequestTimeout(java.util.function.Supplier<Route> inner) |
static Route |
withoutSizeLimit(java.util.function.Supplier<Route> inner) |
static Route |
withPrecompressedMediaTypeSupport(java.util.function.Supplier<Route> inner) |
static Route |
withRangeSupport(java.util.function.Supplier<Route> inner) |
static RouteAdapter |
withRequestTimeout(scala.concurrent.duration.Duration timeout,
java.util.function.Function<HttpRequest,HttpResponse> timeoutHandler,
java.util.function.Supplier<Route> inner) |
static RouteAdapter |
withRequestTimeout(scala.concurrent.duration.Duration timeout,
java.util.function.Supplier<Route> inner) |
static RouteAdapter |
withRequestTimeoutResponse(java.util.function.Function<HttpRequest,HttpResponse> timeoutHandler,
java.util.function.Supplier<Route> inner) |
static Route |
withSettings(RoutingSettings s,
java.util.function.Supplier<Route> inner) |
static Route |
withSizeLimit(long maxBytes,
java.util.function.Supplier<Route> inner) |
public static Route getFromBrowseableDirectories(java.lang.String... directories)
public static Route getFromBrowseableDirectories(scala.collection.immutable.Seq<java.lang.String> directories)
public static Route anyOf(java.util.function.Function<java.util.function.Supplier<Route>,Route> first, java.util.function.Function<java.util.function.Supplier<Route>,Route> second, java.util.function.Supplier<Route> inner)
first(inner).orElse(second(inner))
Usage example:
anyOf(this::get, this::post, () -> complete("hi")))
first
- the first 0-argument directivesecond
- the second 0-argument directiveinner
- the inner route Producerpublic static <A> Route anyOf(java.util.function.Function<java.util.function.Function<A,Route>,Route> first, java.util.function.Function<java.util.function.Function<A,Route>,Route> second, java.util.function.Function<A,Route> inner)
first(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"))
first
- the first 1-argument directivesecond
- the second 1-argument directiveinner
- the inner route that takes one argumentpublic static Route allOf(java.util.function.Function<java.util.function.Supplier<Route>,Route> first, java.util.function.Function<java.util.function.Supplier<Route>,Route> second, java.util.function.Supplier<Route> inner)
allOf(bindParameter(this::pathPrefix, "alice"), bindParameter(this::path, "bob"), () -> complete("Charlie!"))
first
- the 0-argument directive (outer one)second
- the 0-argument directive (inner one)inner
- the inner route functionpublic static <A,B> Route allOf(java.util.function.Function<java.util.function.Function<A,Route>,Route> first, java.util.function.Function<java.util.function.Function<B,Route>,Route> second, java.util.function.BiFunction<A,B,Route> inner)
allOf(this::extractScheme, this::extractMethod, (scheme, method) -> complete("You did a " + method.name() + " using " + scheme))
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 parameterspublic static <A> Route allOf(java.util.function.Function<java.util.function.Supplier<Route>,Route> first, java.util.function.Function<java.util.function.Function<A,Route>,Route> second, java.util.function.Function<A,Route> inner)
allOf(bindParameter(this::pathPrefix, "guess"), this::extractMethod, method -> complete("You did a " + method.name()))
first
- the 0-argument directive (outer one)second
- the 1-argument directive (inner one)inner
- the inner route function that takes 1 parameterpublic static Route mapRequest(java.util.function.Function<HttpRequest,HttpRequest> f, java.util.function.Supplier<Route> inner)
public static Route mapRequestContext(java.util.function.Function<RequestContext,RequestContext> f, java.util.function.Supplier<Route> inner)
public static Route mapRejections(java.util.function.Function<java.util.List<Rejection>,java.util.List<Rejection>> f, java.util.function.Supplier<Route> inner)
public static Route mapResponse(java.util.function.Function<HttpResponse,HttpResponse> f, java.util.function.Supplier<Route> inner)
public static Route mapResponseEntity(java.util.function.Function<ResponseEntity,ResponseEntity> f, java.util.function.Supplier<Route> inner)
public static Route mapResponseHeaders(java.util.function.Function<java.util.List<HttpHeader>,java.util.List<HttpHeader>> f, java.util.function.Supplier<Route> inner)
public static Route mapInnerRoute(java.util.function.Function<Route,Route> f, java.util.function.Supplier<Route> inner)
public static Route mapRouteResult(java.util.function.Function<RouteResult,RouteResult> f, java.util.function.Supplier<Route> inner)
public static Route mapRouteResultPF(scala.PartialFunction<RouteResult,RouteResult> f, java.util.function.Supplier<Route> inner)
public static Route mapRouteResultFuture(java.util.function.Function<java.util.concurrent.CompletionStage<RouteResult>,java.util.concurrent.CompletionStage<RouteResult>> f, java.util.function.Supplier<Route> inner)
public static Route mapRouteResultWith(java.util.function.Function<RouteResult,java.util.concurrent.CompletionStage<RouteResult>> f, java.util.function.Supplier<Route> inner)
public static Route mapRouteResultWithPF(scala.PartialFunction<RouteResult,java.util.concurrent.CompletionStage<RouteResult>> f, java.util.function.Supplier<Route> inner)
public static Route mapSettings(java.util.function.Function<RoutingSettings,RoutingSettings> f, java.util.function.Supplier<Route> inner)
public static Route cancelRejection(Rejection rejection, java.util.function.Supplier<Route> inner)
public static Route cancelRejections(java.lang.Iterable<java.lang.Class<?>> classes, java.util.function.Supplier<Route> inner)
public static Route cancelRejections(java.util.function.Predicate<Rejection> filter, java.util.function.Supplier<Route> inner)
public static Route recoverRejections(java.util.function.Function<java.lang.Iterable<Rejection>,RouteResult> f, java.util.function.Supplier<Route> inner)
public static Route recoverRejectionsWith(java.util.function.Function<java.lang.Iterable<Rejection>,java.util.concurrent.CompletionStage<RouteResult>> f, java.util.function.Supplier<Route> inner)
public static Route mapUnmatchedPath(java.util.function.Function<java.lang.String,java.lang.String> f, java.util.function.Supplier<Route> inner)
public static RouteAdapter extractUnmatchedPath(java.util.function.Function<java.lang.String,Route> inner)
public static RouteAdapter extractMatchedPath(java.util.function.Function<java.lang.String,Route> inner)
public static RouteAdapter extractRequest(java.util.function.Function<HttpRequest,Route> inner)
public static RouteAdapter extractUri(java.util.function.Function<Uri,Route> inner)
public static Route extractEntity(java.util.function.Function<RequestEntity,Route> inner)
public static Route extractMaterializer(java.util.function.Function<org.apache.pekko.stream.Materializer,Route> inner)
public static Route extractActorSystem(java.util.function.Function<org.apache.pekko.actor.ActorSystem,Route> inner)
public static Route extractExecutionContext(java.util.function.Function<scala.concurrent.ExecutionContextExecutor,Route> inner)
public static <T> Route extract(java.util.function.Function<RequestContext,T> extract, java.util.function.Function<T,Route> inner)
public static Route withLog(org.apache.pekko.event.LoggingAdapter log, java.util.function.Supplier<Route> inner)
public static Route withExecutionContext(scala.concurrent.ExecutionContextExecutor ec, java.util.function.Supplier<Route> inner)
public static Route withMaterializer(org.apache.pekko.stream.Materializer mat, java.util.function.Supplier<Route> inner)
public static Route withSettings(RoutingSettings s, java.util.function.Supplier<Route> inner)
public static Route extractLog(java.util.function.Function<org.apache.pekko.event.LoggingAdapter,Route> inner)
public static RouteAdapter extractParserSettings(java.util.function.Function<ParserSettings,Route> inner)
public static RouteAdapter extractSettings(java.util.function.Function<RoutingSettings,Route> inner)
public static RouteAdapter extractRequestContext(java.util.function.Function<RequestContext,Route> inner)
public static RouteAdapter extractDataBytes(java.util.function.Function<org.apache.pekko.stream.javadsl.Source<org.apache.pekko.util.ByteString,java.lang.Object>,Route> inner)
public static Route extractRequestEntity(java.util.function.Function<RequestEntity,Route> inner)
public static Route extractStrictEntity(scala.concurrent.duration.FiniteDuration timeout, java.util.function.Function<HttpEntity.Strict,Route> inner)
public static Route extractStrictEntity(scala.concurrent.duration.FiniteDuration timeout, long maxBytes, java.util.function.Function<HttpEntity.Strict,Route> inner)
public static Route toStrictEntity(scala.concurrent.duration.FiniteDuration timeout, java.util.function.Supplier<Route> inner)
public static Route toStrictEntity(scala.concurrent.duration.FiniteDuration timeout, long maxBytes, java.util.function.Supplier<Route> inner)
public static Route conditional(EntityTag eTag, java.util.function.Supplier<Route> inner)
public static Route conditional(DateTime lastModified, java.util.function.Supplier<Route> inner)
public static Route conditional(EntityTag eTag, DateTime lastModified, java.util.function.Supplier<Route> inner)
public static Route conditional(java.util.Optional<EntityTag> eTag, java.util.Optional<DateTime> lastModified, java.util.function.Supplier<Route> inner)
public static Route responseEncodingAccepted(HttpEncoding encoding, java.util.function.Supplier<Route> inner)
public static Route encodeResponseWith(java.lang.Iterable<Coder> coders, java.util.function.Supplier<Route> inner)
public static Route decodeRequestWith(Coder coder, java.util.function.Supplier<Route> inner)
public static Route requestEncodedWith(HttpEncoding encoding, java.util.function.Supplier<Route> inner)
public static Route decodeRequestWith(java.lang.Iterable<Coder> coders, java.util.function.Supplier<Route> inner)
public static Route withPrecompressedMediaTypeSupport(java.util.function.Supplier<Route> inner)
public static Route cookie(java.lang.String name, java.util.function.Function<HttpCookiePair,Route> inner)
public static Route optionalCookie(java.lang.String name, java.util.function.Function<java.util.Optional<HttpCookiePair>,Route> inner)
public static Route setCookie(HttpCookie cookie, java.util.function.Supplier<Route> inner)
public static Route setCookie(java.lang.Iterable<HttpCookie> cookies, java.util.function.Supplier<Route> inner)
public static Route deleteCookie(HttpCookie cookie, java.util.function.Supplier<Route> inner)
public static Route deleteCookie(java.lang.Iterable<HttpCookie> cookies, java.util.function.Supplier<Route> inner)
public static Route deleteCookie(java.lang.String name, java.util.function.Supplier<Route> inner)
public static Route deleteCookie(java.lang.String name, java.lang.String domain, java.util.function.Supplier<Route> inner)
public static Route deleteCookie(java.lang.String name, java.lang.String domain, java.lang.String path, java.util.function.Supplier<Route> inner)
public static Route logRequest(java.lang.String marker, java.util.function.Supplier<Route> inner)
public static Route logRequest(java.lang.String marker, org.apache.pekko.event.Logging.LogLevel level, java.util.function.Supplier<Route> inner)
public static Route logRequest(java.util.function.Function<HttpRequest,LogEntry> show, java.util.function.Supplier<Route> inner)
public static Route logResult(java.lang.String marker, java.util.function.Supplier<Route> inner)
public static Route logResult(java.lang.String marker, org.apache.pekko.event.Logging.LogLevel level, java.util.function.Supplier<Route> inner)
public static RouteAdapter logResult(java.util.function.Function<HttpResponse,LogEntry> showSuccess, java.util.function.Function<java.util.List<Rejection>,LogEntry> showRejection, java.util.function.Supplier<Route> inner)
public static RouteAdapter logRequestResult(java.util.function.BiFunction<HttpRequest,HttpResponse,LogEntry> showSuccess, java.util.function.BiFunction<HttpRequest,java.util.List<Rejection>,LogEntry> showRejection, java.util.function.Supplier<Route> inner)
public static RouteAdapter logRequestResultOptional(java.util.function.BiFunction<HttpRequest,HttpResponse,java.util.Optional<LogEntry>> showSuccess, java.util.function.BiFunction<HttpRequest,java.util.List<Rejection>,java.util.Optional<LogEntry>> showRejection, java.util.function.Supplier<Route> inner)
public static RouteAdapter handleExceptions(ExceptionHandler handler, java.util.function.Supplier<Route> inner)
public static RouteAdapter handleRejections(RejectionHandler handler, java.util.function.Supplier<Route> inner)
public static Route getFromResource(java.lang.String path)
public static Route getFromResource(java.lang.String path, ContentTypeResolver resolver)
public static Route getFromResource(java.lang.String path, ContentType contentType)
public static Route getFromResource(java.lang.String path, ContentType contentType, java.lang.ClassLoader classLoader)
public static Route getFromResourceDirectory(java.lang.String directoryName)
public static Route getFromResourceDirectory(java.lang.String directoryName, java.lang.ClassLoader classLoader)
public static Route getFromResourceDirectory(java.lang.String directoryName, ContentTypeResolver resolver)
public static Route getFromResourceDirectory(java.lang.String directoryName, ContentTypeResolver resolver, java.lang.ClassLoader classLoader)
public static Route getFromFile(java.io.File file)
public static Route getFromFile(java.io.File file, ContentTypeResolver resolver)
public static Route getFromFile(java.io.File file, ContentType contentType)
public static Route getFromFile(java.lang.String file)
public static Route getFromFile(java.lang.String file, ContentTypeResolver resolver)
public static Route getFromDirectory(java.lang.String directoryPath)
public static Route getFromDirectory(java.lang.String directoryPath, ContentTypeResolver resolver)
public static Route getFromBrowseableDirectory(java.lang.String directory, DirectoryRenderer renderer, ContentTypeResolver resolver)
public static Route getFromBrowseableDirectory(java.lang.String directory, DirectoryRenderer renderer)
public static Route getFromBrowseableDirectory(java.lang.String directory, ContentTypeResolver resolver)
public static Route getFromBrowseableDirectory(java.lang.String directory)
public static Route listDirectoryContents(scala.collection.immutable.Seq<java.lang.String> directories)
public static Route listDirectoryContents(DirectoryRenderer directoryRenderer, scala.collection.immutable.Seq<java.lang.String> directories)
public static DirectoryRenderer defaultDirectoryRenderer()
public static ContentTypeResolver defaultContentTypeResolver()
public static Route listDirectoryContents(java.lang.String... directories)
public static Route listDirectoryContents(DirectoryRenderer directoryRenderer, java.lang.String... directories)
public static Route storeUploadedFile(java.lang.String fieldName, java.util.function.Function<FileInfo,java.io.File> destFn, java.util.function.BiFunction<FileInfo,java.io.File,Route> inner)
public static Route storeUploadedFiles(java.lang.String fieldName, java.util.function.Function<FileInfo,java.io.File> destFn, java.util.function.Function<java.util.List<java.util.Map.Entry<FileInfo,java.io.File>>,Route> inner)
public static Route fileUpload(java.lang.String fieldName, java.util.function.BiFunction<FileInfo,org.apache.pekko.stream.javadsl.Source<org.apache.pekko.util.ByteString,java.lang.Object>,Route> inner)
public static Route fileUploadAll(java.lang.String fieldName, java.util.function.Function<java.util.List<java.util.Map.Entry<FileInfo,org.apache.pekko.stream.javadsl.Source<org.apache.pekko.util.ByteString,java.lang.Object>>>,Route> inner)
public static Route formField(java.lang.String name, java.util.function.Function<java.lang.String,Route> inner)
public static Route formFieldOptional(java.lang.String name, java.util.function.Function<java.util.Optional<java.lang.String>,Route> inner)
public static Route formFieldList(java.lang.String name, java.util.function.Function<java.util.List<java.lang.String>,Route> inner)
public static <T> Route formField(Unmarshaller<java.lang.String,T> t, java.lang.String name, java.util.function.Function<T,Route> inner)
public static <T> Route formFieldOptional(Unmarshaller<java.lang.String,T> t, java.lang.String name, java.util.function.Function<java.util.Optional<T>,Route> inner)
public static <T> Route formFieldList(Unmarshaller<java.lang.String,T> t, java.lang.String name, java.util.function.Function<java.util.List<T>,Route> inner)
public static Route formFieldMap(java.util.function.Function<java.util.Map<java.lang.String,java.lang.String>,Route> inner)
public static Route formFieldMultiMap(java.util.function.Function<java.util.Map<java.lang.String,java.util.List<java.lang.String>>,Route> inner)
public static Route formFieldList(java.util.function.Function<java.util.List<java.util.Map.Entry<java.lang.String,java.lang.String>>,Route> inner)
public static <T> RouteAdapter onComplete(java.util.function.Supplier<java.util.concurrent.CompletionStage<T>> f, java.util.function.Function<scala.util.Try<T>,Route> inner)
public static <T> RouteAdapter onComplete(java.util.concurrent.CompletionStage<T> cs, java.util.function.Function<scala.util.Try<T>,Route> inner)
public static <T> RouteAdapter onCompleteWithBreaker(org.apache.pekko.pattern.CircuitBreaker breaker, java.util.function.Supplier<java.util.concurrent.CompletionStage<T>> f, java.util.function.Function<scala.util.Try<T>,Route> inner)
public static <T> RouteAdapter onSuccess(java.util.function.Supplier<java.util.concurrent.CompletionStage<T>> f, java.util.function.Function<T,Route> inner)
public static <T> RouteAdapter onSuccess(java.util.concurrent.CompletionStage<T> cs, java.util.function.Function<T,Route> inner)
public static <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)
public static Route checkSameOrigin(HttpOriginRange allowed, java.util.function.Supplier<Route> inner)
public static <T> RouteAdapter headerValue(java.util.function.Function<HttpHeader,java.util.Optional<T>> f, java.util.function.Function<T,Route> inner)
public static <T> RouteAdapter headerValuePF(scala.PartialFunction<HttpHeader,T> pf, java.util.function.Function<T,Route> inner)
public static RouteAdapter headerValueByName(java.lang.String headerName, java.util.function.Function<java.lang.String,Route> inner)
public static <T extends HttpHeader> RouteAdapter headerValueByType(java.lang.Class<T> t, java.util.function.Function<T,Route> inner)
public static <T> RouteAdapter optionalHeaderValue(java.util.function.Function<HttpHeader,java.util.Optional<T>> f, java.util.function.Function<java.util.Optional<T>,Route> inner)
public static <T> RouteAdapter optionalHeaderValuePF(scala.PartialFunction<HttpHeader,T> pf, java.util.function.Function<java.util.Optional<T>,Route> inner)
public static RouteAdapter optionalHeaderValueByName(java.lang.String headerName, java.util.function.Function<java.util.Optional<java.lang.String>,Route> inner)
public static <T extends HttpHeader> RouteAdapter optionalHeaderValueByType(java.lang.Class<T> t, java.util.function.Function<java.util.Optional<T>,Route> inner)
public static <T> RouteAdapter attribute(AttributeKey<T> key, java.util.function.Function<T,Route> inner)
public static <T> RouteAdapter optionalAttribute(AttributeKey<T> key, java.util.function.Function<java.util.Optional<T>,Route> inner)
public static Route extractHost(java.util.function.Function<java.lang.String,Route> inner)
public static Route host(java.lang.Iterable<java.lang.String> hostNames, java.util.function.Supplier<Route> inner)
public static Route host(java.util.function.Predicate<java.lang.String> predicate, java.util.function.Supplier<Route> inner)
public static Route host(java.util.regex.Pattern regex, java.util.function.Function<java.lang.String,Route> inner)
public static <T> Route request(Unmarshaller<? super HttpRequest,T> unmarshaller, java.util.function.Function<T,Route> inner)
public static <T> Route entity(Unmarshaller<? super HttpEntity,T> unmarshaller, java.util.function.Function<T,Route> inner)
public static <T> Route completeWith(Marshaller<T,? extends HttpResponse> marshaller, java.util.function.Consumer<java.util.function.Consumer<T>> inner)
public static <T,R> Route handleWith(Unmarshaller<? super HttpEntity,T> unmarshaller, Marshaller<R,? extends HttpResponse> marshaller, java.util.function.Function<T,R> inner)
public static RouteAdapter extractMethod(java.util.function.Function<HttpMethod,Route> inner)
public static Route method(HttpMethod method, java.util.function.Supplier<Route> inner)
public static Route overrideMethodWithParameter(java.lang.String paramName, java.util.function.Supplier<Route> inner)
public static Route validate(java.util.function.BooleanSupplier check, java.lang.String errorMsg, java.util.function.Supplier<Route> inner)
public static Route extractClientIP(java.util.function.Function<RemoteAddress,Route> inner)
public static Route requestEntityPresent(java.util.function.Supplier<Route> inner)
public static Route rejectEmptyResponse(java.util.function.Supplier<Route> inner)
public static Route withSizeLimit(long maxBytes, java.util.function.Supplier<Route> inner)
public static Route selectPreferredLanguage(java.lang.Iterable<Language> languages, java.util.function.Function<Language,Route> inner)
public static Route parameter(java.lang.String name, java.util.function.Function<java.lang.String,Route> inner)
public static Route parameterOptional(java.lang.String name, java.util.function.Function<java.util.Optional<java.lang.String>,Route> inner)
public static <T> Route parameterRequiredValue(Unmarshaller<java.lang.String,T> t, T requiredValue, java.lang.String name, java.util.function.Supplier<Route> inner)
public static Route parameterList(java.lang.String name, java.util.function.Function<java.util.List<java.lang.String>,Route> inner)
public static <T> Route parameter(Unmarshaller<java.lang.String,T> t, java.lang.String name, java.util.function.Function<T,Route> inner)
public static <T> Route parameterOptional(Unmarshaller<java.lang.String,T> t, java.lang.String name, java.util.function.Function<java.util.Optional<T>,Route> inner)
public static <T> Route parameterOrDefault(Unmarshaller<java.lang.String,T> t, T defaultValue, java.lang.String name, java.util.function.Function<T,Route> inner)
public static <T> Route parameterList(Unmarshaller<java.lang.String,T> t, java.lang.String name, java.util.function.Function<java.util.List<T>,Route> inner)
public static Route parameterMap(java.util.function.Function<java.util.Map<java.lang.String,java.lang.String>,Route> inner)
public static Route parameterMultiMap(java.util.function.Function<java.util.Map<java.lang.String,java.util.List<java.lang.String>>,Route> inner)
public static Route parameterList(java.util.function.Function<java.util.List<java.util.Map.Entry<java.lang.String,java.lang.String>>,Route> inner)
public static Route pathEndOrSingleSlash(java.util.function.Supplier<Route> inner)
public static Route path(PathMatcher0 p, java.util.function.Supplier<Route> inner)
public static <T> Route path(PathMatcher1<T> p, java.util.function.Function<T,Route> inner)
public static <T1,T2> Route path(PathMatcher2<T1,T2> p, java.util.function.BiFunction<T1,T2,Route> inner)
public static Route pathPrefix(java.lang.String segment, java.util.function.Supplier<Route> inner)
public static Route pathPrefix(java.util.function.Function<java.lang.String,Route> inner)
public static Route pathPrefix(PathMatcher0 p, java.util.function.Supplier<Route> inner)
public static <T> Route pathPrefix(PathMatcher1<T> p, java.util.function.Function<T,Route> inner)
public static <T1,T2> Route pathPrefix(PathMatcher2<T1,T2> p, java.util.function.BiFunction<T1,T2,Route> inner)
public static Route rawPathPrefix(java.lang.String segment, java.util.function.Supplier<Route> inner)
public static Route rawPathPrefix(PathMatcher0 pm, java.util.function.Supplier<Route> inner)
public static <T1> Route rawPathPrefix(PathMatcher1<T1> pm, java.util.function.Function<T1,Route> inner)
public static <T1,T2> Route rawPathPrefix(PathMatcher2<T1,T2> pm, java.util.function.BiFunction<T1,T2,Route> inner)
public static Route pathPrefixTest(java.lang.String segment, java.util.function.Supplier<Route> inner)
public static Route pathPrefixTest(PathMatcher0 pm, java.util.function.Supplier<Route> inner)
public static <T1> Route pathPrefixTest(PathMatcher1<T1> pm, java.util.function.Function<T1,Route> inner)
public static <T1,T2> Route pathPrefixTest(PathMatcher2<T1,T2> pm, java.util.function.BiFunction<T1,T2,Route> inner)
public static Route rawPathPrefixTest(java.lang.String segment, java.util.function.Supplier<Route> inner)
public static Route rawPathPrefixTest(PathMatcher0 pm, java.util.function.Supplier<Route> inner)
public static <T1> Route rawPathPrefixTest(PathMatcher1<T1> pm, java.util.function.Function<T1,Route> inner)
public static <T1,T2> Route rawPathPrefixTest(PathMatcher2<T1,T2> pm, java.util.function.BiFunction<T1,T2,Route> inner)
public static Route pathSuffix(java.lang.String segment, java.util.function.Supplier<Route> inner)
public static Route pathSuffix(PathMatcher0 pm, java.util.function.Supplier<Route> inner)
public static <T1> Route pathSuffix(PathMatcher1<T1> pm, java.util.function.Function<T1,Route> inner)
public static <T1,T2> Route pathSuffix(PathMatcher2<T1,T2> pm, java.util.function.BiFunction<T1,T2,Route> inner)
public static Route pathSuffixTest(java.lang.String segment, java.util.function.Supplier<Route> inner)
public static Route pathSuffixTest(PathMatcher0 pm, java.util.function.Supplier<Route> inner)
public static <T1> Route pathSuffixTest(PathMatcher1<T1> pm, java.util.function.Function<T1,Route> inner)
public static <T1,T2> Route pathSuffixTest(PathMatcher2<T1,T2> pm, java.util.function.BiFunction<T1,T2,Route> inner)
public static Route redirectToTrailingSlashIfMissing(StatusCode redirectionType, java.util.function.Supplier<Route> inner)
public static Route redirectToNoTrailingSlashIfPresent(StatusCode redirectionType, java.util.function.Supplier<Route> inner)
public static <T> Route pathPrefix(Unmarshaller<java.lang.String,T> t, java.util.function.Function<T,Route> inner)
public static <T> Route path(Unmarshaller<java.lang.String,T> t, java.util.function.Function<T,Route> inner)
public static Route ignoreTrailingSlash(java.util.function.Supplier<Route> inner)
public static Route respondWithHeader(HttpHeader responseHeader, java.util.function.Supplier<Route> inner)
public static Route respondWithDefaultHeader(HttpHeader responseHeader, java.util.function.Supplier<Route> inner)
public static Route respondWithHeaders(java.lang.Iterable<HttpHeader> responseHeaders, java.util.function.Supplier<Route> inner)
public static Route respondWithDefaultHeaders(java.lang.Iterable<HttpHeader> responseHeaders, java.util.function.Supplier<Route> inner)
public static Route reject(Rejection rejection, scala.collection.immutable.Seq<Rejection> rejections)
public static Route reject()
public static Route redirect(Uri uri, StatusCode redirectionType)
public static Route failWith(java.lang.Throwable error)
public static Route complete(java.lang.String body)
public static Route complete(HttpResponse response)
public static Route complete(StatusCode status)
public static <T> RouteAdapter complete(T value, Marshaller<T,HttpResponse> marshaller)
public static <T> RouteAdapter complete(StatusCode status, java.lang.Iterable<HttpHeader> headers, T value, Marshaller<T,RequestEntity> marshaller)
public static RouteAdapter complete(StatusCode status, java.lang.Iterable<HttpHeader> headers, ResponseEntity entity)
public static RouteAdapter complete(StatusCode status, java.lang.Iterable<HttpHeader> headers, RequestEntity entity)
public static <T> RouteAdapter complete(StatusCode status, T value, Marshaller<T,RequestEntity> marshaller)
public static RouteAdapter complete(StatusCode status, ResponseEntity entity)
public static RouteAdapter complete(StatusCode status, RequestEntity entity)
public static RouteAdapter complete(StatusCode status, java.lang.String entity)
public static <T> RouteAdapter complete(java.lang.Iterable<HttpHeader> headers, T value, Marshaller<T,RequestEntity> marshaller)
public static RouteAdapter complete(java.lang.Iterable<HttpHeader> headers, ResponseEntity entity)
public static RouteAdapter complete(java.lang.Iterable<HttpHeader> headers, RequestEntity entity)
public static <T> RouteAdapter completeOK(T value, Marshaller<T,RequestEntity> marshaller)
public static RouteAdapter complete(ResponseEntity entity)
public static RouteAdapter complete(RequestEntity entity)
public static RouteAdapter completeWithFutureResponse(scala.concurrent.Future<HttpResponse> value)
public static RouteAdapter completeOKWithFutureString(scala.concurrent.Future<java.lang.String> value)
public static Route completeWithFutureStatus(scala.concurrent.Future<StatusCode> status)
public static <T> RouteAdapter completeOKWithFuture(scala.concurrent.Future<T> value, Marshaller<T,RequestEntity> marshaller)
public static <T> RouteAdapter completeWithFuture(scala.concurrent.Future<T> value, Marshaller<T,HttpResponse> marshaller)
public static RouteAdapter completeWithFuture(java.util.concurrent.CompletionStage<HttpResponse> value)
public static RouteAdapter completeOKWithFuture(java.util.concurrent.CompletionStage<RequestEntity> value)
public static RouteAdapter completeOKWithFutureString(java.util.concurrent.CompletionStage<java.lang.String> value)
public static Route completeWithFutureStatus(java.util.concurrent.CompletionStage<StatusCode> status)
public static <T> RouteAdapter completeOKWithFuture(java.util.concurrent.CompletionStage<T> value, Marshaller<T,RequestEntity> marshaller)
public static <T> RouteAdapter completeWithFuture(java.util.concurrent.CompletionStage<T> value, Marshaller<T,HttpResponse> marshaller)
public static Route handle(org.apache.pekko.japi.function.Function<HttpRequest,java.util.concurrent.CompletionStage<HttpResponse>> handler)
public static Route handleSync(org.apache.pekko.japi.function.Function<HttpRequest,HttpResponse> handler)
public static Route extractScheme(java.util.function.Function<java.lang.String,Route> inner)
public static Route extractCredentials(java.util.function.Function<java.util.Optional<HttpCredentials>,Route> inner)
public static <T> Route authenticateBasic(java.lang.String realm, java.util.function.Function<java.util.Optional<SecurityDirectives.ProvidedCredentials>,java.util.Optional<T>> authenticator, java.util.function.Function<T,Route> inner)
public static <T> Route authenticateBasicPF(java.lang.String realm, scala.PartialFunction<java.util.Optional<SecurityDirectives.ProvidedCredentials>,T> authenticator, java.util.function.Function<T,Route> inner)
public static <T> Route authenticateBasicPFAsync(java.lang.String realm, scala.PartialFunction<java.util.Optional<SecurityDirectives.ProvidedCredentials>,java.util.concurrent.CompletionStage<T>> authenticator, java.util.function.Function<T,Route> inner)
public static <T> Route authenticateBasicOptional(java.lang.String realm, java.util.function.Function<java.util.Optional<SecurityDirectives.ProvidedCredentials>,java.util.Optional<T>> authenticator, java.util.function.Function<java.util.Optional<T>,Route> inner)
public static <T> Route authenticateBasicAsync(java.lang.String realm, java.util.function.Function<java.util.Optional<SecurityDirectives.ProvidedCredentials>,java.util.concurrent.CompletionStage<java.util.Optional<T>>> authenticator, java.util.function.Function<T,Route> inner)
public static <T> Route authenticateBasicAsyncOptional(java.lang.String realm, java.util.function.Function<java.util.Optional<SecurityDirectives.ProvidedCredentials>,java.util.concurrent.CompletionStage<java.util.Optional<T>>> authenticator, java.util.function.Function<java.util.Optional<T>,Route> inner)
public static <T> Route authenticateOAuth2(java.lang.String realm, java.util.function.Function<java.util.Optional<SecurityDirectives.ProvidedCredentials>,java.util.Optional<T>> authenticator, java.util.function.Function<T,Route> inner)
public static <T> Route authenticateOAuth2Optional(java.lang.String realm, java.util.function.Function<java.util.Optional<SecurityDirectives.ProvidedCredentials>,java.util.Optional<T>> authenticator, java.util.function.Function<java.util.Optional<T>,Route> inner)
public static <T> Route authenticateOAuth2Async(java.lang.String realm, java.util.function.Function<java.util.Optional<SecurityDirectives.ProvidedCredentials>,java.util.concurrent.CompletionStage<java.util.Optional<T>>> authenticator, java.util.function.Function<T,Route> inner)
public static <T> Route authenticateOAuth2AsyncOptional(java.lang.String realm, java.util.function.Function<java.util.Optional<SecurityDirectives.ProvidedCredentials>,java.util.concurrent.CompletionStage<java.util.Optional<T>>> authenticator, java.util.function.Function<java.util.Optional<T>,Route> inner)
public static <T> Route authenticateOrRejectWithChallenge(java.util.function.Function<java.util.Optional<HttpCredentials>,java.util.concurrent.CompletionStage<scala.util.Either<HttpChallenge,T>>> authenticator, java.util.function.Function<T,Route> inner)
public static <C extends HttpCredentials,T> Route authenticateOrRejectWithChallenge(java.lang.Class<C> c, java.util.function.Function<java.util.Optional<C>,java.util.concurrent.CompletionStage<scala.util.Either<HttpChallenge,T>>> authenticator, java.util.function.Function<T,Route> inner)
public static Route authorize(java.util.function.Supplier<java.lang.Object> check, java.util.function.Supplier<Route> inner)
public static Route authorizeWithRequestContext(org.apache.pekko.japi.function.Function<RequestContext,java.lang.Object> check, java.util.function.Supplier<Route> inner)
public static Route authorizeAsync(java.util.function.Supplier<java.util.concurrent.CompletionStage<java.lang.Object>> check, java.util.function.Supplier<Route> inner)
public static Route authorizeAsyncWithRequestContext(org.apache.pekko.japi.function.Function<RequestContext,java.util.concurrent.CompletionStage<java.lang.Object>> check, java.util.function.Supplier<Route> inner)
public static Route extractUpgradeToWebSocket(java.util.function.Function<UpgradeToWebSocket,Route> inner)
public static Route extractWebSocketUpgrade(java.util.function.Function<WebSocketUpgrade,Route> inner)
public static Route extractOfferedWsProtocols(java.util.function.Function<java.util.List<java.lang.String>,Route> inner)
public static <T> Route handleWebSocketMessages(org.apache.pekko.stream.javadsl.Flow<Message,Message,T> handler)
public static <T> Route handleWebSocketMessagesForProtocol(org.apache.pekko.stream.javadsl.Flow<Message,Message,T> handler, java.lang.String subprotocol)
public static <T> Route handleWebSocketMessagesForOptionalProtocol(org.apache.pekko.stream.javadsl.Flow<Message,Message,T> handler, java.util.Optional<java.lang.String> subprotocol)
public static RouteAdapter extractRequestTimeout(java.util.function.Function<scala.concurrent.duration.Duration,Route> inner)
public static RouteAdapter withRequestTimeout(scala.concurrent.duration.Duration timeout, java.util.function.Supplier<Route> inner)
public static RouteAdapter withRequestTimeout(scala.concurrent.duration.Duration timeout, java.util.function.Function<HttpRequest,HttpResponse> timeoutHandler, java.util.function.Supplier<Route> inner)
public static RouteAdapter withoutRequestTimeout(java.util.function.Supplier<Route> inner)
public static RouteAdapter withRequestTimeoutResponse(java.util.function.Function<HttpRequest,HttpResponse> timeoutHandler, java.util.function.Supplier<Route> inner)
public static <T> Route entityAsSourceOf(Unmarshaller<org.apache.pekko.util.ByteString,T> um, EntityStreamingSupport support, java.util.function.Function<org.apache.pekko.stream.javadsl.Source<T,org.apache.pekko.NotUsed>,Route> inner)
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)
public static <T,M> Route completeOKWithSource(org.apache.pekko.stream.javadsl.Source<T,M> source, Marshaller<T,RequestEntity> m, EntityStreamingSupport support)