Package org.apache.dubbo.remoting.http12
Class AbstractServerHttpChannelObserver<H extends HttpChannel>
java.lang.Object
org.apache.dubbo.remoting.http12.AbstractServerHttpChannelObserver<H>
- All Implemented Interfaces:
AutoCloseable,StreamObserver<Object>,ServerHttpChannelObserver<H>
- Direct Known Subclasses:
Http1ServerChannelObserver,Http2ServerChannelObserver
public abstract class AbstractServerHttpChannelObserver<H extends HttpChannel>
extends Object
implements ServerHttpChannelObserver<H>
-
Method Summary
Modifier and TypeMethodDescriptionvoidaddHeadersCustomizer(BiConsumer<HttpHeaders, Throwable> headersCustomizer) voidaddTrailersCustomizer(BiConsumer<HttpHeaders, Throwable> trailersCustomizer) voidclose()final voidfinal voidfinal voidvoidsetExceptionCustomizer(Function<Throwable, ?> exceptionCustomizer) voidsetResponseEncoder(HttpMessageEncoder responseEncoder)
-
Method Details
-
getHttpChannel
- Specified by:
getHttpChannelin interfaceServerHttpChannelObserver<H extends HttpChannel>
-
addHeadersCustomizer
- Specified by:
addHeadersCustomizerin interfaceServerHttpChannelObserver<H extends HttpChannel>
-
addTrailersCustomizer
- Specified by:
addTrailersCustomizerin interfaceServerHttpChannelObserver<H extends HttpChannel>
-
setExceptionCustomizer
- Specified by:
setExceptionCustomizerin interfaceServerHttpChannelObserver<H extends HttpChannel>
-
getResponseEncoder
-
setResponseEncoder
-
onNext
- Specified by:
onNextin interfaceStreamObserver<H extends HttpChannel>
-
onError
- Specified by:
onErrorin interfaceStreamObserver<H extends HttpChannel>
-
onCompleted
public final void onCompleted()- Specified by:
onCompletedin interfaceStreamObserver<H extends HttpChannel>
-
close
public void close()- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceServerHttpChannelObserver<H extends HttpChannel>
-