Top Description Inners Fields Constructors Methods
org.springframework.http.server.reactive

public Class UndertowHttpHandlerAdapter

extends Object
implements HttpHandler
Class Inheritance
All Implemented Interfaces
io.undertow.server.HttpHandler
Imports
java.io.IOException, java.net.URISyntaxException, io.undertow.server.HttpServerExchange, org.apache.commons.logging.Log, org.reactivestreams.Subscriber, .Subscription, org.springframework.core.io.buffer.DataBufferFactory, .DefaultDataBufferFactory, org.springframework.http.HttpLogging, .HttpMethod, org.springframework.util.Assert
Adapt HttpHandler to the Undertow io.undertow.server.HttpHandler.
Authors
Marek Hawrylczak, Rossen Stoyanchev, Arjen Poutsma
Since
5.0

Nested and Inner Type Summary

Modifier and TypeClass and Description
private static class
UndertowHttpHandlerAdapter.HandlerResultSubscriber

Field Summary

Modifier and TypeField and Description
private DataBufferFactory
bufferFactory

private final HttpHandler
httpHandler

private static final Log
logger

Constructor Summary

AccessConstructor and Description
public
UndertowHttpHandlerAdapter(HttpHandler httpHandler)

Method Summary

Modifier and TypeMethod and Description
public DataBufferFactory
getDataBufferFactory()

public void
handleRequest(HttpServerExchange
the HTTP request/response exchange
exchange)

Implements io.undertow.server.HttpHandler.handleRequest.

Handle the request.

public void
setDataBufferFactory(DataBufferFactory bufferFactory)

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

bufferFactoryback to summary
private DataBufferFactory bufferFactory
httpHandlerback to summary
private final HttpHandler httpHandler
loggerback to summary
private static final Log logger

Constructor Detail

UndertowHttpHandlerAdapterback to summary
public UndertowHttpHandlerAdapter(HttpHandler httpHandler)

Method Detail

getDataBufferFactoryback to summary
public DataBufferFactory getDataBufferFactory()
handleRequestback to summary
public void handleRequest(HttpServerExchange exchange)

Implements io.undertow.server.HttpHandler.handleRequest.

Doc from io.undertow.server.HttpHandler.handleRequest.

Handle the request.

Parameters
exchange:HttpServerExchange

the HTTP request/response exchange

Annotations
@Override
setDataBufferFactoryback to summary
public void setDataBufferFactory(DataBufferFactory bufferFactory)
org.springframework.http.server.reactive back to summary

private Class UndertowHttpHandlerAdapter.HandlerResultSubscriber

extends Object
implements Subscriber<Void>
Class Inheritance
  • java.lang.Object
  • org.springframework.http.server.reactive.UndertowHttpHandlerAdapter.HandlerResultSubscriber
All Implemented Interfaces
org.reactivestreams.Subscriber

Field Summary

Modifier and TypeField and Description
private final HttpServerExchange
exchange

private final String
logPrefix

Constructor Summary

AccessConstructor and Description
public
HandlerResultSubscriber(HttpServerExchange exchange, UndertowServerHttpRequest request)

Method Summary

Modifier and TypeMethod and Description
public void
onComplete()

Implements org.reactivestreams.Subscriber.onComplete.

Successful terminal state.

public void
onError(Throwable
the throwable signaled
ex)

Implements org.reactivestreams.Subscriber.onError.

Failed terminal state.

public void
onNext(Void
the element signaled
aVoid)

Implements org.reactivestreams.Subscriber.onNext.

Data notification sent by the Publisher in response to requests to Subscription#request(long).

public void
onSubscribe(Subscription
the Subscription that allows requesting data via Subscription#request(long)
subscription)

Implements org.reactivestreams.Subscriber.onSubscribe.

Invoked after calling Publisher#subscribe(Subscriber).

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

exchangeback to summary
private final HttpServerExchange exchange
logPrefixback to summary
private final String logPrefix

Constructor Detail

HandlerResultSubscriberback to summary
public HandlerResultSubscriber(HttpServerExchange exchange, UndertowServerHttpRequest request)

Method Detail

onCompleteback to summary
public void onComplete()

Implements org.reactivestreams.Subscriber.onComplete.

Doc from org.reactivestreams.Subscriber.onComplete.

Successful terminal state.

No further events will be sent even if Subscription#request(long) is invoked again.

Annotations
@Override
onErrorback to summary
public void onError(Throwable ex)

Implements org.reactivestreams.Subscriber.onError.

Doc from org.reactivestreams.Subscriber.onError.

Failed terminal state.

No further events will be sent even if Subscription#request(long) is invoked again.

Parameters
ex:Throwable

the throwable signaled

Annotations
@Override
onNextback to summary
public void onNext(Void aVoid)

Implements org.reactivestreams.Subscriber.onNext.

Doc from org.reactivestreams.Subscriber.onNext.

Data notification sent by the Publisher in response to requests to Subscription#request(long).

Parameters
aVoid:Void

the element signaled

Annotations
@Override
onSubscribeback to summary
public void onSubscribe(Subscription subscription)

Implements org.reactivestreams.Subscriber.onSubscribe.

Doc from org.reactivestreams.Subscriber.onSubscribe.

Invoked after calling Publisher#subscribe(Subscriber).

No data will start flowing until Subscription#request(long) is invoked.

It is the responsibility of this Subscriber instance to call Subscription#request(long) whenever more data is wanted.

The Publisher will send notifications only in response to Subscription#request(long).

Parameters
subscription:Subscription

the Subscription that allows requesting data via Subscription#request(long)

Annotations
@Override