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 Type	Method	Description
void	addHeadersCustomizer(BiConsumer<HttpHeaders,Throwable> headersCustomizer)
void	addTrailersCustomizer(BiConsumer<HttpHeaders,Throwable> trailersCustomizer)
void	close()
H	getHttpChannel()
HttpMessageEncoder	getResponseEncoder()
final void	onCompleted()
final void	onError(Throwable throwable)
final void	onNext(Object data)
void	setExceptionCustomizer(Function<Throwable,?> exceptionCustomizer)
void	setResponseEncoder(HttpMessageEncoder responseEncoder)

Methods inherited from class java.lang.Object

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

Method Details

getHttpChannel

public H getHttpChannel()

Specified by:

getHttpChannel in interface ServerHttpChannelObserver<H extends HttpChannel>

addHeadersCustomizer

public void addHeadersCustomizer(BiConsumer<HttpHeaders,Throwable> headersCustomizer)

Specified by:

addHeadersCustomizer in interface ServerHttpChannelObserver<H extends HttpChannel>

addTrailersCustomizer

public void addTrailersCustomizer(BiConsumer<HttpHeaders,Throwable> trailersCustomizer)

Specified by:

addTrailersCustomizer in interface ServerHttpChannelObserver<H extends HttpChannel>

setExceptionCustomizer

public void setExceptionCustomizer(Function<Throwable,?> exceptionCustomizer)

Specified by:

setExceptionCustomizer in interface ServerHttpChannelObserver<H extends HttpChannel>

getResponseEncoder

public HttpMessageEncoder getResponseEncoder()

setResponseEncoder

public void setResponseEncoder(HttpMessageEncoder responseEncoder)

onNext

public final void onNext(Object data)

Specified by:

onNext in interface StreamObserver<H extends HttpChannel>

onError

public final void onError(Throwable throwable)

Specified by:

onError in interface StreamObserver<H extends HttpChannel>

onCompleted

public final void onCompleted()

Specified by:

onCompleted in interface StreamObserver<H extends HttpChannel>

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface ServerHttpChannelObserver<H extends HttpChannel>