Package org.apache.pekko.http.javadsl.server.directives

Class FramedEntityStreamingDirectives

java.lang.Object

org.apache.pekko.http.javadsl.server.directives.BasicDirectives

org.apache.pekko.http.javadsl.server.directives.CacheConditionDirectives

org.apache.pekko.http.javadsl.server.directives.CodingDirectives

org.apache.pekko.http.javadsl.server.directives.CookieDirectives

org.apache.pekko.http.javadsl.server.directives.DebuggingDirectives

org.apache.pekko.http.javadsl.server.directives.ExecutionDirectives

org.apache.pekko.http.javadsl.server.directives.FileAndResourceDirectives

org.apache.pekko.http.javadsl.server.directives.FileUploadDirectives

org.apache.pekko.http.javadsl.server.directives.FormFieldDirectives

org.apache.pekko.http.javadsl.server.directives.FutureDirectives

org.apache.pekko.http.javadsl.server.directives.HeaderDirectives

org.apache.pekko.http.javadsl.server.directives.AttributeDirectives

org.apache.pekko.http.javadsl.server.directives.HostDirectives

org.apache.pekko.http.javadsl.server.directives.MarshallingDirectives

org.apache.pekko.http.javadsl.server.directives.MethodDirectives

org.apache.pekko.http.javadsl.server.directives.MiscDirectives

org.apache.pekko.http.javadsl.server.directives.ParameterDirectives

org.apache.pekko.http.javadsl.server.directives.PathDirectives

org.apache.pekko.http.javadsl.server.directives.RangeDirectives

org.apache.pekko.http.javadsl.server.directives.RespondWithDirectives

org.apache.pekko.http.javadsl.server.directives.RouteDirectives

org.apache.pekko.http.javadsl.server.directives.SchemeDirectives

org.apache.pekko.http.javadsl.server.directives.SecurityDirectives

org.apache.pekko.http.javadsl.server.directives.WebSocketDirectives

org.apache.pekko.http.javadsl.server.directives.TimeoutDirectives

org.apache.pekko.http.javadsl.server.directives.FramedEntityStreamingDirectives

Direct Known Subclasses:

AllDirectives, FramedEntityStreamingDirectives$

public abstract class FramedEntityStreamingDirectives
extends TimeoutDirectives

EXPERIMENTAL API

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.pekko.http.javadsl.server.directives.SecurityDirectives

SecurityDirectives.ProvidedCredentials, SecurityDirectives.ProvidedCredentials$

Constructor Summary

Constructors

Constructor	Description
FramedEntityStreamingDirectives()

Method Summary

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

Methods inherited from class org.apache.pekko.http.javadsl.server.directives.TimeoutDirectives

extractRequestTimeout, withoutRequestTimeout, withRequestTimeout, withRequestTimeout, withRequestTimeout, withRequestTimeout, withRequestTimeoutResponse

Methods inherited from class org.apache.pekko.http.javadsl.server.directives.WebSocketDirectives

extractOfferedWsProtocols, extractWebSocketUpgrade, handleWebSocketMessages, handleWebSocketMessagesForOptionalProtocol, handleWebSocketMessagesForProtocol

Methods inherited from class org.apache.pekko.http.javadsl.server.directives.SecurityDirectives

authenticateBasic, authenticateBasicAsync, authenticateBasicAsyncOptional, authenticateBasicOptional, authenticateBasicPF, authenticateBasicPFAsync, authenticateOAuth2, authenticateOAuth2Async, authenticateOAuth2AsyncOptional, authenticateOAuth2Optional, authenticateOrRejectWithChallenge, authenticateOrRejectWithChallenge, authorize, authorizeAsync, authorizeAsyncWithRequestContext, authorizeWithRequestContext, extractCredentials

Methods inherited from class org.apache.pekko.http.javadsl.server.directives.SchemeDirectives

extractScheme, scheme

Methods inherited from class org.apache.pekko.http.javadsl.server.directives.RouteDirectives

complete, complete, complete, complete, complete, complete, complete, complete, complete, complete, complete, complete, complete, complete, complete, complete, completeOK, completeOKWithFuture, completeOKWithFuture, completeOKWithFuture, completeOKWithFutureString, completeOKWithFutureString, completeWithFuture, completeWithFuture, completeWithFuture, completeWithFutureResponse, completeWithFutureStatus, completeWithFutureStatus, concat, concat, failWith, handle, handleSync, redirect, reject, reject, reject, route, route

Methods inherited from class org.apache.pekko.http.javadsl.server.directives.RespondWithDirectives

respondWithDefaultHeader, respondWithDefaultHeaders, respondWithHeader, respondWithHeaders

Methods inherited from class org.apache.pekko.http.javadsl.server.directives.RangeDirectives

withRangeSupport

Methods inherited from class org.apache.pekko.http.javadsl.server.directives.PathDirectives

ignoreTrailingSlash, path, path, path, path, path, path, pathEnd, pathEndOrSingleSlash, pathPrefix, pathPrefix, pathPrefix, pathPrefix, pathPrefix, pathPrefix, pathPrefixTest, pathPrefixTest, pathPrefixTest, pathPrefixTest, pathSingleSlash, pathSuffix, pathSuffix, pathSuffix, pathSuffix, pathSuffixTest, pathSuffixTest, pathSuffixTest, pathSuffixTest, rawPathPrefix, rawPathPrefix, rawPathPrefix, rawPathPrefix, rawPathPrefixTest, rawPathPrefixTest, rawPathPrefixTest, rawPathPrefixTest, redirectToNoTrailingSlashIfPresent, redirectToTrailingSlashIfMissing

Methods inherited from class org.apache.pekko.http.javadsl.server.directives.ParameterDirectives

parameter, parameter, parameterList, parameterList, parameterList, parameterMap, parameterMultiMap, parameterOptional, parameterOptional, parameterOrDefault, parameterRequiredValue

Methods inherited from class org.apache.pekko.http.javadsl.server.directives.MiscDirectives

extractClientIP, rejectEmptyResponse, requestEntityEmpty, requestEntityPresent, selectPreferredLanguage, validate, withoutSizeLimit, withSizeLimit

Methods inherited from class org.apache.pekko.http.javadsl.server.directives.MethodDirectives

delete, extractMethod, get, head, method, options, overrideMethodWithParameter, patch, post, put

Methods inherited from class org.apache.pekko.http.javadsl.server.directives.MarshallingDirectives

completeWith, entity, handleWith, request

Methods inherited from class org.apache.pekko.http.javadsl.server.directives.HostDirectives

extractHost, host, host, host, host

Methods inherited from class org.apache.pekko.http.javadsl.server.directives.AttributeDirectives

attribute, optionalAttribute

Methods inherited from class org.apache.pekko.http.javadsl.server.directives.HeaderDirectives

checkSameOrigin, headerValue, headerValueByName, headerValueByType, headerValuePF, optionalHeaderValue, optionalHeaderValueByName, optionalHeaderValueByType, optionalHeaderValuePF

Methods inherited from class org.apache.pekko.http.javadsl.server.directives.FutureDirectives

completeOrRecoverWith, onComplete, onComplete, onCompleteWithBreaker, onSuccess, onSuccess

Methods inherited from class org.apache.pekko.http.javadsl.server.directives.FormFieldDirectives

formField, formField, formFieldList, formFieldList, formFieldList, formFieldMap, formFieldMultiMap, formFieldOptional, formFieldOptional

Methods inherited from class org.apache.pekko.http.javadsl.server.directives.FileUploadDirectives

fileUpload, fileUploadAll, storeUploadedFile, storeUploadedFiles

Methods inherited from class org.apache.pekko.http.javadsl.server.directives.FileAndResourceDirectives

defaultContentTypeResolver, defaultDirectoryRenderer, getFromBrowseableDirectories, getFromBrowseableDirectories, getFromBrowseableDirectories, getFromBrowseableDirectories, getFromBrowseableDirectories, getFromBrowseableDirectory, getFromBrowseableDirectory, getFromBrowseableDirectory, getFromBrowseableDirectory, getFromDirectory, getFromDirectory, getFromFile, getFromFile, getFromFile, getFromFile, getFromFile, getFromResource, getFromResource, getFromResource, getFromResource, getFromResourceDirectory, getFromResourceDirectory, getFromResourceDirectory, getFromResourceDirectory, listDirectoryContents, listDirectoryContents, listDirectoryContents, listDirectoryContents

Methods inherited from class org.apache.pekko.http.javadsl.server.directives.ExecutionDirectives

handleExceptions, handleRejections

Methods inherited from class org.apache.pekko.http.javadsl.server.directives.DebuggingDirectives

logRequest, logRequest, logRequest, logRequestResult, logRequestResultOptional, logResult, logResult, logResult

Methods inherited from class org.apache.pekko.http.javadsl.server.directives.CookieDirectives

cookie, deleteCookie, deleteCookie, deleteCookie, deleteCookie, deleteCookie, optionalCookie, setCookie, setCookie

Methods inherited from class org.apache.pekko.http.javadsl.server.directives.CodingDirectives

decodeRequest, decodeRequestWith, decodeRequestWith, encodeResponse, encodeResponseWith, requestEncodedWith, responseEncodingAccepted, withPrecompressedMediaTypeSupport

Methods inherited from class org.apache.pekko.http.javadsl.server.directives.CacheConditionDirectives

conditional, conditional, conditional, conditional

Methods inherited from class org.apache.pekko.http.javadsl.server.directives.BasicDirectives

cancelRejection, cancelRejections, cancelRejections, extract, extractActorSystem, extractDataBytes, extractEntity, extractExecutionContext, extractLog, extractMatchedPath, extractMaterializer, extractParserSettings, extractRequest, extractRequestContext, extractRequestEntity, extractSettings, extractStrictEntity, extractStrictEntity, extractStrictEntity, extractStrictEntity, extractUnmatchedPath, extractUri, mapInnerRoute, mapRejections, mapRequest, mapRequestContext, mapResponse, mapResponseEntity, mapResponseHeaders, mapRouteResult, mapRouteResultFuture, mapRouteResultPF, mapRouteResultWith, mapRouteResultWithPF, mapSettings, mapUnmatchedPath, pass, provide, recoverRejections, recoverRejectionsWith, toStrictEntity, toStrictEntity, toStrictEntity, toStrictEntity, withExecutionContext, withLog, withMaterializer, withSettings

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

FramedEntityStreamingDirectives

public FramedEntityStreamingDirectives()

Method Details

mapRequest

public static Route mapRequest(Function<HttpRequest,HttpRequest> f,
 Supplier<Route> inner)

mapRequestContext

public static Route mapRequestContext(Function<RequestContext,RequestContext> f,
 Supplier<Route> inner)

mapRejections

public static Route mapRejections(Function<List<Rejection>,List<Rejection>> f,
 Supplier<Route> inner)

mapResponse

public static Route mapResponse(Function<HttpResponse,HttpResponse> f,
 Supplier<Route> inner)

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

public static Route mapInnerRoute(Function<Route,Route> f,
 Supplier<Route> inner)

mapRouteResult

public static Route mapRouteResult(Function<RouteResult,RouteResult> f,
 Supplier<Route> inner)

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

public static Route mapSettings(Function<RoutingSettings,RoutingSettings> f,
 Supplier<Route> inner)

pass

public static Route pass(Supplier<Route> inner)

provide

public static <T> Route provide(T t,
 Function<T,Route> inner)

cancelRejection

public static Route cancelRejection(Rejection rejection,
 Supplier<Route> inner)

cancelRejections

public static Route cancelRejections(Iterable<Class<?>> classes,
 Supplier<Route> inner)

cancelRejections

public static Route cancelRejections(Predicate<Rejection> filter,
 Supplier<Route> inner)

recoverRejections

public static Route recoverRejections(Function<Iterable<Rejection>,RouteResult> f,
 Supplier<Route> inner)

recoverRejectionsWith

public static Route recoverRejectionsWith(Function<Iterable<Rejection>,CompletionStage<RouteResult>> f,
 Supplier<Route> inner)

mapUnmatchedPath

public static Route mapUnmatchedPath(Function<String,String> f,
 Supplier<Route> inner)

extractUnmatchedPath

public static RouteAdapter extractUnmatchedPath(Function<String,Route> inner)

extractMatchedPath

public static RouteAdapter extractMatchedPath(Function<String,Route> inner)

extractRequest

public static RouteAdapter extractRequest(Function<HttpRequest,Route> inner)

extractUri

public static RouteAdapter extractUri(Function<Uri,Route> inner)

extractEntity

public static Route extractEntity(Function<RequestEntity,Route> inner)

extractMaterializer

public static Route extractMaterializer(Function<org.apache.pekko.stream.Materializer,Route> inner)

extractActorSystem

public static Route extractActorSystem(Function<org.apache.pekko.actor.ActorSystem,Route> inner)

extractExecutionContext

public static Route extractExecutionContext(Function<scala.concurrent.ExecutionContextExecutor,Route> inner)

extract

public static <T> Route extract(Function<RequestContext,T> extract,
 Function<T,Route> inner)

withLog

public static Route withLog(org.apache.pekko.event.LoggingAdapter log,
 Supplier<Route> inner)

withExecutionContext

public static Route withExecutionContext(scala.concurrent.ExecutionContextExecutor ec,
 Supplier<Route> inner)

withMaterializer

public static Route withMaterializer(org.apache.pekko.stream.Materializer mat,
 Supplier<Route> inner)

withSettings

public static Route withSettings(RoutingSettings s,
 Supplier<Route> inner)

extractLog

public static Route extractLog(Function<org.apache.pekko.event.LoggingAdapter,Route> inner)

extractParserSettings

public static RouteAdapter extractParserSettings(Function<ParserSettings,Route> inner)

extractSettings

public static RouteAdapter extractSettings(Function<RoutingSettings,Route> inner)

extractRequestContext

public static RouteAdapter extractRequestContext(Function<RequestContext,Route> inner)

extractDataBytes

public static RouteAdapter extractDataBytes(Function<org.apache.pekko.stream.javadsl.Source<org.apache.pekko.util.ByteString,Object>,Route> inner)

extractRequestEntity

public static Route extractRequestEntity(Function<RequestEntity,Route> inner)

extractStrictEntity

public static Route extractStrictEntity(scala.concurrent.duration.FiniteDuration timeout,
 Function<HttpEntity.Strict,Route> inner)

extractStrictEntity

public static Route extractStrictEntity(Duration timeout,
 Function<HttpEntity.Strict,Route> inner)

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

public static Route toStrictEntity(scala.concurrent.duration.FiniteDuration timeout,
 Supplier<Route> inner)

toStrictEntity

public static Route toStrictEntity(Duration timeout,
 Supplier<Route> inner)

toStrictEntity

public static Route toStrictEntity(scala.concurrent.duration.FiniteDuration timeout,
 long maxBytes,
 Supplier<Route> inner)

toStrictEntity

public static Route toStrictEntity(Duration timeout,
 long maxBytes,
 Supplier<Route> inner)

conditional

public static Route conditional(EntityTag eTag,
 Supplier<Route> inner)

conditional

public static Route conditional(DateTime lastModified,
 Supplier<Route> inner)

conditional

public static Route conditional(EntityTag eTag,
 DateTime lastModified,
 Supplier<Route> inner)

conditional

public static Route conditional(Optional<EntityTag> eTag,
 Optional<DateTime> lastModified,
 Supplier<Route> inner)

responseEncodingAccepted

public static Route responseEncodingAccepted(HttpEncoding encoding,
 Supplier<Route> inner)

encodeResponse

public static Route encodeResponse(Supplier<Route> inner)

encodeResponseWith

public static Route encodeResponseWith(Iterable<Coder> coders,
 Supplier<Route> inner)

decodeRequestWith

public static Route decodeRequestWith(Coder coder,
 Supplier<Route> inner)

requestEncodedWith

public static Route requestEncodedWith(HttpEncoding encoding,
 Supplier<Route> inner)

decodeRequestWith

public static Route decodeRequestWith(Iterable<Coder> coders,
 Supplier<Route> inner)

decodeRequest

public static Route decodeRequest(Supplier<Route> inner)

withPrecompressedMediaTypeSupport

public static Route withPrecompressedMediaTypeSupport(Supplier<Route> inner)

cookie

public static Route cookie(String name,
 Function<HttpCookiePair,Route> inner)

optionalCookie

public static Route optionalCookie(String name,
 Function<Optional<HttpCookiePair>,Route> inner)

setCookie

public static Route setCookie(HttpCookie cookie,
 Supplier<Route> inner)

setCookie

public static Route setCookie(Iterable<HttpCookie> cookies,
 Supplier<Route> inner)

deleteCookie

public static Route deleteCookie(HttpCookie cookie,
 Supplier<Route> inner)

deleteCookie

public static Route deleteCookie(Iterable<HttpCookie> cookies,
 Supplier<Route> inner)

deleteCookie

public static Route deleteCookie(String name,
 Supplier<Route> inner)

deleteCookie

public static Route deleteCookie(String name,
 String domain,
 Supplier<Route> inner)

deleteCookie

public static Route deleteCookie(String name,
 String domain,
 String path,
 Supplier<Route> inner)

logRequest

public static Route logRequest(String marker,
 Supplier<Route> inner)

logRequest

public static Route logRequest(String marker,
 org.apache.pekko.event.Logging.LogLevel level,
 Supplier<Route> inner)

logRequest

public static Route logRequest(Function<HttpRequest,LogEntry> show,
 Supplier<Route> inner)

logResult

public static Route logResult(String marker,
 Supplier<Route> inner)

logResult

public static Route logResult(String marker,
 org.apache.pekko.event.Logging.LogLevel level,
 Supplier<Route> inner)

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

public static RouteAdapter handleExceptions(ExceptionHandler handler,
 Supplier<Route> inner)

handleRejections

public static RouteAdapter handleRejections(RejectionHandler handler,
 Supplier<Route> inner)

getFromResource

public static Route getFromResource(String path)

getFromResource

public static Route getFromResource(String path,
 ContentTypeResolver resolver)

getFromResource

public static Route getFromResource(String path,
 ContentType contentType)

getFromResource

public static Route getFromResource(String path,
 ContentType contentType,
 ClassLoader classLoader)

getFromResourceDirectory

public static Route getFromResourceDirectory(String directoryName)

getFromResourceDirectory

public static Route getFromResourceDirectory(String directoryName,
 ClassLoader classLoader)

getFromResourceDirectory

public static Route getFromResourceDirectory(String directoryName,
 ContentTypeResolver resolver)

getFromResourceDirectory

public static Route getFromResourceDirectory(String directoryName,
 ContentTypeResolver resolver,
 ClassLoader classLoader)

getFromFile

public static Route getFromFile(File file)

getFromFile

public static Route getFromFile(File file,
 ContentTypeResolver resolver)

getFromFile

public static Route getFromFile(File file,
 ContentType contentType)

getFromFile

public static Route getFromFile(String file)

getFromFile

public static Route getFromFile(String file,
 ContentTypeResolver resolver)

getFromDirectory

public static Route getFromDirectory(String directoryPath)

getFromDirectory

public static Route getFromDirectory(String directoryPath,
 ContentTypeResolver resolver)

getFromBrowseableDirectory

public static Route getFromBrowseableDirectory(String directory,
 DirectoryRenderer renderer,
 ContentTypeResolver resolver)

getFromBrowseableDirectory

public static Route getFromBrowseableDirectory(String directory,
 DirectoryRenderer renderer)

getFromBrowseableDirectory

public static Route getFromBrowseableDirectory(String directory,
 ContentTypeResolver resolver)

getFromBrowseableDirectory

public static Route getFromBrowseableDirectory(String directory)

getFromBrowseableDirectories

public static Route getFromBrowseableDirectories(Iterable<String> directories,
 DirectoryRenderer renderer,
 ContentTypeResolver resolver)

getFromBrowseableDirectories

public static Route getFromBrowseableDirectories(Iterable<String> directories,
 DirectoryRenderer renderer)

getFromBrowseableDirectories

public static Route getFromBrowseableDirectories(Iterable<String> directories,
 ContentTypeResolver resolver)

getFromBrowseableDirectories

public static Route getFromBrowseableDirectories(scala.collection.immutable.Seq<String> directories)

listDirectoryContents

public static Route listDirectoryContents(scala.collection.immutable.Seq<String> directories)

listDirectoryContents

public static Route listDirectoryContents(DirectoryRenderer directoryRenderer,
 scala.collection.immutable.Seq<String> directories)

defaultDirectoryRenderer

public static DirectoryRenderer defaultDirectoryRenderer()

defaultContentTypeResolver

public static ContentTypeResolver defaultContentTypeResolver()

getFromBrowseableDirectories

public static Route getFromBrowseableDirectories(String... directories)

listDirectoryContents

public static Route listDirectoryContents(String... directories)

listDirectoryContents

public static Route listDirectoryContents(DirectoryRenderer directoryRenderer,
 String... directories)

storeUploadedFile

public static Route storeUploadedFile(String fieldName,
 Function<FileInfo,File> destFn,
 BiFunction<FileInfo,File,Route> inner)

storeUploadedFiles

public static Route storeUploadedFiles(String fieldName,
 Function<FileInfo,File> destFn,
 Function<List<Map.Entry<FileInfo,File>>,Route> inner)

fileUpload

public static Route fileUpload(String fieldName,
 BiFunction<FileInfo,org.apache.pekko.stream.javadsl.Source<org.apache.pekko.util.ByteString,Object>,Route> inner)

fileUploadAll

public static Route fileUploadAll(String fieldName,
 Function<List<Map.Entry<FileInfo,org.apache.pekko.stream.javadsl.Source<org.apache.pekko.util.ByteString,Object>>>,Route> inner)

formField

public static Route formField(String name,
 Function<String,Route> inner)

formFieldOptional

public static Route formFieldOptional(String name,
 Function<Optional<String>,Route> inner)

formFieldList

public static Route formFieldList(String name,
 Function<List<String>,Route> inner)

formField

public static <T> Route formField(Unmarshaller<String,T> t,
 String name,
 Function<T,Route> inner)

formFieldOptional

public static <T> Route formFieldOptional(Unmarshaller<String,T> t,
 String name,
 Function<Optional<T>,Route> inner)

formFieldList

public static <T> Route formFieldList(Unmarshaller<String,T> t,
 String name,
 Function<List<T>,Route> inner)

formFieldMap

public static Route formFieldMap(Function<Map<String,String>,Route> inner)

formFieldMultiMap

public static Route formFieldMultiMap(Function<Map<String,List<String>>,Route> inner)

formFieldList

public static Route formFieldList(Function<List<Map.Entry<String,String>>,Route> inner)

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

public static <T> RouteAdapter onSuccess(Supplier<CompletionStage<T>> f,
 Function<T,Route> inner)

onSuccess

public static <T> RouteAdapter onSuccess(CompletionStage<T> cs,
 Function<T,Route> inner)

completeOrRecoverWith

public static <T> Route completeOrRecoverWith(Supplier<CompletionStage<T>> f,
 Marshaller<T,RequestEntity> marshaller,
 Function<Throwable,Route> inner)

checkSameOrigin

public static Route checkSameOrigin(HttpOriginRange allowed,
 Supplier<Route> inner)

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

public static RouteAdapter headerValueByName(String headerName,
 Function<String,Route> inner)

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

public static RouteAdapter optionalHeaderValueByName(String headerName,
 Function<Optional<String>,Route> inner)

optionalHeaderValueByType

public static <T extends HttpHeader> RouteAdapter optionalHeaderValueByType(Class<T> t,
 Function<Optional<T>,Route> inner)

attribute

public static <T> RouteAdapter attribute(AttributeKey<T> key,
 Function<T,Route> inner)

optionalAttribute

public static <T> RouteAdapter optionalAttribute(AttributeKey<T> key,
 Function<Optional<T>,Route> inner)

extractHost

public static Route extractHost(Function<String,Route> inner)

host

public static Route host(Iterable<String> hostNames,
 Supplier<Route> inner)

host

public static Route host(String hostName,
 Supplier<Route> inner)

host

public static Route host(Predicate<String> predicate,
 Supplier<Route> inner)

host

public static Route host(Pattern regex,
 Function<String,Route> inner)

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

public static Route delete(Supplier<Route> inner)

get

public static Route get(Supplier<Route> inner)

head

public static Route head(Supplier<Route> inner)

options

public static Route options(Supplier<Route> inner)

patch

public static Route patch(Supplier<Route> inner)

post

public static Route post(Supplier<Route> inner)

put

public static Route put(Supplier<Route> inner)

extractMethod

public static RouteAdapter extractMethod(Function<HttpMethod,Route> inner)

method

public static Route method(HttpMethod method,
 Supplier<Route> inner)

overrideMethodWithParameter

public static Route overrideMethodWithParameter(String paramName,
 Supplier<Route> inner)

validate

public static Route validate(BooleanSupplier check,
 String errorMsg,
 Supplier<Route> inner)

extractClientIP

public static Route extractClientIP(Function<RemoteAddress,Route> inner)

requestEntityEmpty

public static Route requestEntityEmpty(Supplier<Route> inner)

requestEntityPresent

public static Route requestEntityPresent(Supplier<Route> inner)

rejectEmptyResponse

public static Route rejectEmptyResponse(Supplier<Route> inner)

withSizeLimit

public static Route withSizeLimit(long maxBytes,
 Supplier<Route> inner)

withoutSizeLimit

public static Route withoutSizeLimit(Supplier<Route> inner)

selectPreferredLanguage

public static Route selectPreferredLanguage(Iterable<Language> languages,
 Function<Language,Route> inner)

parameter

public static Route parameter(String name,
 Function<String,Route> inner)

parameterOptional

public static Route parameterOptional(String name,
 Function<Optional<String>,Route> inner)

parameterRequiredValue

public static <T> Route parameterRequiredValue(Unmarshaller<String,T> t,
 T requiredValue,
 String name,
 Supplier<Route> inner)

parameterList

public static Route parameterList(String name,
 Function<List<String>,Route> inner)

parameter

public static <T> Route parameter(Unmarshaller<String,T> t,
 String name,
 Function<T,Route> inner)

parameterOptional

public static <T> Route parameterOptional(Unmarshaller<String,T> t,
 String name,
 Function<Optional<T>,Route> inner)

parameterOrDefault

public static <T> Route parameterOrDefault(Unmarshaller<String,T> t,
 T defaultValue,
 String name,
 Function<T,Route> inner)

parameterList

public static <T> Route parameterList(Unmarshaller<String,T> t,
 String name,
 Function<List<T>,Route> inner)

parameterMap

public static Route parameterMap(Function<Map<String,String>,Route> inner)

parameterMultiMap

public static Route parameterMultiMap(Function<Map<String,List<String>>,Route> inner)

parameterList

public static Route parameterList(Function<List<Map.Entry<String,String>>,Route> inner)

pathEnd

public static Route pathEnd(Supplier<Route> inner)

pathEndOrSingleSlash

public static Route pathEndOrSingleSlash(Supplier<Route> inner)

pathSingleSlash

public static Route pathSingleSlash(Supplier<Route> inner)

path

public static Route path(String segment,
 Supplier<Route> inner)

path

public static Route path(Function<String,Route> inner)

path

public static Route path(PathMatcher0 p,
 Supplier<Route> inner)

path

public static <T> Route path(PathMatcher1<T> p,
 Function<T,Route> inner)

path

public static <T1,
T2> Route path(PathMatcher2<T1,T2> p,
 BiFunction<T1,T2,Route> inner)

pathPrefix

public static Route pathPrefix(String segment,
 Supplier<Route> inner)

pathPrefix

public static Route pathPrefix(Function<String,Route> inner)

pathPrefix

public static Route pathPrefix(PathMatcher0 p,
 Supplier<Route> inner)

pathPrefix

public static <T> Route pathPrefix(PathMatcher1<T> p,
 Function<T,Route> inner)

pathPrefix

public static <T1,
T2> Route pathPrefix(PathMatcher2<T1,T2> p,
 BiFunction<T1,T2,Route> inner)

rawPathPrefix

public static Route rawPathPrefix(String segment,
 Supplier<Route> inner)

rawPathPrefix

public static Route rawPathPrefix(PathMatcher0 pm,
 Supplier<Route> inner)

rawPathPrefix

public static <T1> Route rawPathPrefix(PathMatcher1<T1> pm,
 Function<T1,Route> inner)

rawPathPrefix

public static <T1,
T2> Route rawPathPrefix(PathMatcher2<T1,T2> pm,
 BiFunction<T1,T2,Route> inner)

pathPrefixTest

public static Route pathPrefixTest(String segment,
 Supplier<Route> inner)

pathPrefixTest

public static Route pathPrefixTest(PathMatcher0 pm,
 Supplier<Route> inner)

pathPrefixTest

public static <T1> Route pathPrefixTest(PathMatcher1<T1> pm,
 Function<T1,Route> inner)

pathPrefixTest

public static <T1,
T2> Route pathPrefixTest(PathMatcher2<T1,T2> pm,
 BiFunction<T1,T2,Route> inner)

rawPathPrefixTest

public static Route rawPathPrefixTest(String segment,
 Supplier<Route> inner)

rawPathPrefixTest

public static Route rawPathPrefixTest(PathMatcher0 pm,
 Supplier<Route> inner)

rawPathPrefixTest

public static <T1> Route rawPathPrefixTest(PathMatcher1<T1> pm,
 Function<T1,Route> inner)

rawPathPrefixTest

public static <T1,
T2> Route rawPathPrefixTest(PathMatcher2<T1,T2> pm,
 BiFunction<T1,T2,Route> inner)

pathSuffix

public static Route pathSuffix(String segment,
 Supplier<Route> inner)

pathSuffix

public static Route pathSuffix(PathMatcher0 pm,
 Supplier<Route> inner)

pathSuffix

public static <T1> Route pathSuffix(PathMatcher1<T1> pm,
 Function<T1,Route> inner)

pathSuffix

public static <T1,
T2> Route pathSuffix(PathMatcher2<T1,T2> pm,
 BiFunction<T1,T2,Route> inner)

pathSuffixTest

public static Route pathSuffixTest(String segment,
 Supplier<Route> inner)

pathSuffixTest

public static Route pathSuffixTest(PathMatcher0 pm,
 Supplier<Route> inner)

pathSuffixTest

public static <T1> Route pathSuffixTest(PathMatcher1<T1> pm,
 Function<T1,Route> inner)

pathSuffixTest

public static <T1,
T2> Route pathSuffixTest(PathMatcher2<T1,T2> pm,
 BiFunction<T1,T2,Route> inner)

redirectToTrailingSlashIfMissing

public static Route redirectToTrailingSlashIfMissing(StatusCode redirectionType,
 Supplier<Route> inner)

redirectToNoTrailingSlashIfPresent

public static Route redirectToNoTrailingSlashIfPresent(StatusCode redirectionType,
 Supplier<Route> inner)

pathPrefix

public static <T> Route pathPrefix(Unmarshaller<String,T> t,
 Function<T,Route> inner)

path

public static <T> Route path(Unmarshaller<String,T> t,
 Function<T,Route> inner)

ignoreTrailingSlash

public static Route ignoreTrailingSlash(Supplier<Route> inner)

withRangeSupport

public static Route withRangeSupport(Supplier<Route> inner)

respondWithHeader

public static Route respondWithHeader(HttpHeader responseHeader,
 Supplier<Route> inner)

respondWithDefaultHeader

public static Route respondWithDefaultHeader(HttpHeader responseHeader,
 Supplier<Route> inner)

respondWithHeaders

public static Route respondWithHeaders(Iterable<HttpHeader> responseHeaders,
 Supplier<Route> inner)

respondWithDefaultHeaders

public static Route respondWithDefaultHeaders(Iterable<HttpHeader> responseHeaders,
 Supplier<Route> inner)

route

public static Route route(scala.collection.immutable.Seq<Route> alternatives)

concat

public static Route concat(Route first,
 scala.collection.immutable.Seq<Route> alternatives)

reject

public static Route reject(Rejection rejection,
 scala.collection.immutable.Seq<Rejection> rejections)

reject

public static Route reject()

redirect

public static Route redirect(Uri uri,
 StatusCode redirectionType)

failWith

public static Route failWith(Throwable error)

complete

public static Route complete(String body)

complete

public static Route complete(HttpResponse response)

complete

public static Route complete(StatusCode status)

complete

public static <T> RouteAdapter complete(T value,
 Marshaller<T,HttpResponse> marshaller)

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

public static RouteAdapter complete(StatusCode status,
 ResponseEntity entity)

complete

public static RouteAdapter complete(StatusCode status,
 RequestEntity entity)

complete

public static RouteAdapter complete(StatusCode status,
 String entity)

complete

public static <T> RouteAdapter complete(Iterable<HttpHeader> headers,
 T value,
 Marshaller<T,RequestEntity> marshaller)

complete

public static RouteAdapter complete(Iterable<HttpHeader> headers,
 ResponseEntity entity)

complete

public static RouteAdapter complete(Iterable<HttpHeader> headers,
 RequestEntity entity)

completeOK

public static <T> RouteAdapter completeOK(T value,
 Marshaller<T,RequestEntity> marshaller)

complete

public static RouteAdapter complete(ResponseEntity entity)

complete

public static RouteAdapter complete(RequestEntity entity)

completeWithFutureResponse

public static RouteAdapter completeWithFutureResponse(scala.concurrent.Future<HttpResponse> value)

completeOKWithFutureString

public static RouteAdapter completeOKWithFutureString(scala.concurrent.Future<String> value)

completeWithFutureStatus

public static Route completeWithFutureStatus(scala.concurrent.Future<StatusCode> status)

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

public static RouteAdapter completeWithFuture(CompletionStage<HttpResponse> value)

completeOKWithFuture

public static RouteAdapter completeOKWithFuture(CompletionStage<RequestEntity> value)

completeOKWithFutureString

public static RouteAdapter completeOKWithFutureString(CompletionStage<String> value)

completeWithFutureStatus

public static Route completeWithFutureStatus(CompletionStage<StatusCode> status)

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)

route

public static Route route(Route... alternatives)

concat

public static Route concat(Route first,
 Route... alternatives)

reject

public static Route reject(Rejection rejection,
 Rejection... rejections)

extractScheme

public static Route extractScheme(Function<String,Route> inner)

scheme

public static Route scheme(String name,
 Supplier<Route> inner)

extractCredentials

public static Route extractCredentials(Function<Optional<HttpCredentials>,Route> inner)

authenticateBasic

public static <T> Route authenticateBasic(String realm,
 Function<Optional<SecurityDirectives.ProvidedCredentials>,Optional<T>> authenticator,
 Function<T,Route> inner)

authenticateBasicPF

public static <T> Route authenticateBasicPF(String realm,
 scala.PartialFunction<Optional<SecurityDirectives.ProvidedCredentials>,T> authenticator,
 Function<T,Route> inner)

authenticateBasicPFAsync

public static <T> Route authenticateBasicPFAsync(String realm,
 scala.PartialFunction<Optional<SecurityDirectives.ProvidedCredentials>,CompletionStage<T>> authenticator,
 Function<T,Route> inner)

authenticateBasicOptional

public static <T> Route authenticateBasicOptional(String realm,
 Function<Optional<SecurityDirectives.ProvidedCredentials>,Optional<T>> authenticator,
 Function<Optional<T>,Route> inner)

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

public static <T> Route authenticateOAuth2(String realm,
 Function<Optional<SecurityDirectives.ProvidedCredentials>,Optional<T>> authenticator,
 Function<T,Route> inner)

authenticateOAuth2Optional

public static <T> Route authenticateOAuth2Optional(String realm,
 Function<Optional<SecurityDirectives.ProvidedCredentials>,Optional<T>> authenticator,
 Function<Optional<T>,Route> inner)

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

public static Route authorize(Supplier<Object> check,
 Supplier<Route> inner)

authorizeWithRequestContext

public static Route authorizeWithRequestContext(org.apache.pekko.japi.function.Function<RequestContext,Object> check,
 Supplier<Route> inner)

authorizeAsync

public static Route authorizeAsync(Supplier<CompletionStage<Object>> check,
 Supplier<Route> inner)

authorizeAsyncWithRequestContext

public static Route authorizeAsyncWithRequestContext(org.apache.pekko.japi.function.Function<RequestContext,CompletionStage<Object>> check,
 Supplier<Route> inner)

extractWebSocketUpgrade

public static Route extractWebSocketUpgrade(Function<WebSocketUpgrade,Route> inner)

extractOfferedWsProtocols

public static Route extractOfferedWsProtocols(Function<List<String>,Route> inner)

handleWebSocketMessages

public static <T> Route handleWebSocketMessages(org.apache.pekko.stream.javadsl.Flow<Message,Message,T> handler)

handleWebSocketMessagesForProtocol

public static <T> Route handleWebSocketMessagesForProtocol(org.apache.pekko.stream.javadsl.Flow<Message,Message,T> handler,
 String subprotocol)

handleWebSocketMessagesForOptionalProtocol

public static <T> Route handleWebSocketMessagesForOptionalProtocol(org.apache.pekko.stream.javadsl.Flow<Message,Message,T> handler,
 Optional<String> subprotocol)

extractRequestTimeout

public static RouteAdapter extractRequestTimeout(Function<scala.concurrent.duration.Duration,Route> inner)

withRequestTimeout

public static RouteAdapter withRequestTimeout(scala.concurrent.duration.Duration timeout,
 Supplier<Route> inner)

withRequestTimeout

public static RouteAdapter withRequestTimeout(Duration timeout,
 Supplier<Route> inner)

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

public static RouteAdapter withoutRequestTimeout(Supplier<Route> inner)

withRequestTimeoutResponse

public static RouteAdapter withRequestTimeoutResponse(Function<HttpRequest,HttpResponse> timeoutHandler,
 Supplier<Route> inner)

entityAsSourceOf

public <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 <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 <T,
M> Route completeOKWithSource(org.apache.pekko.stream.javadsl.Source<T,M> source,
 Marshaller<T,RequestEntity> m,
 EntityStreamingSupport support)