Dependencies
- avalon-framework/avalon-framework/4.1.5 (available as org.apache.avalon.framework/avalon-framework-impl/4.3.1)
- com.github.jponge/lzma-java/1.3
- com.github.spotbugs/spotbugs-annotations/4.0.3
- com.google.code.findbugs/jsr305/3.0.2
- com.google.protobuf.nano/protobuf-javanano/3.0.0-alpha-5
- com.google.protobuf/protobuf-java/2.6.1
- com.jcraft/jzlib/1.1.3
- commons-logging/commons-logging/1.2
- com.ning/compress-lzf/1.0.3
- io.micronaut/micronaut-aop/2.2.0
- io.micronaut/micronaut-buffer-netty/2.2.0
- io.micronaut/micronaut-core/2.2.0
- io.micronaut/micronaut-http/2.2.0
- io.micronaut/micronaut-inject/2.2.0
- io.micronaut/micronaut-websocket/2.2.0
- io.netty/netty-buffer/4.1.54.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec/4.1.54.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-http2/4.1.54.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-http/4.1.54.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-common/4.1.54.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-handler/4.1.54.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-resolver/4.1.54.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-tcnative/2.0.34.Final
- io.netty/netty-transport/4.1.54.Final (available as io.netty/netty-all/4.1.25.Final)
- io.projectreactor.tools/blockhound/1.0.3.RELEASE
- io.reactivex.rxjava2/rxjava/2.2.10
- java/11
- javax.annotation/javax.annotation-api/1.3.2
- javax.inject/javax.inject/1
- log4j/log4j/1.2.17
- logkit/logkit/1.0.1
- net.jpountz.lz4/lz4/1.3.0
- org.apache.geronimo.specs/geronimo-jms_1.1_spec/1.0
- org.apache.logging.log4j/log4j-api/2.6.2
- org.bouncycastle/bcpkix-jdk15on/1.65
- org.bouncycastle/bcprov-jdk15on/1.65
- org.conscrypt/conscrypt-openjdk-uber/2.5.1
- org.jboss.marshalling/jboss-marshalling/1.4.11.Final
- org.reactivestreams/reactive-streams/1.0.2
- org.slf4j/slf4j-api/1.7.26
- org.yaml/snakeyaml/1.26
Declarations
-
io
-
micronaut
-
http
-
netty
-
AbstractNettyHttpRequest
- path: String
- locale: Locale
- STREAM_ID: AsciiString
- HTTP2_SCHEME: AsciiString
- nettyRequest: HttpRequest
- conversionService: ConversionService<ConversionService>
- httpMethod: HttpMethod
- uri: URI
- httpMethodName: String
- httpParameters: NettyHttpParameters
- mediaType: MediaType
- charset: Charset
- accept: Collection<MediaType>
- AbstractNettyHttpRequest(HttpRequest, ConversionService): void
- toHttpRequest(): HttpRequest
- toFullHttpRequest(): FullHttpRequest
- toStreamHttpRequest(): StreamedHttpRequest
- isStream(): boolean
- getHttpVersion(): HttpVersion
- getNettyRequest(): HttpRequest
- getParameters(): HttpParameters
- accept(): Collection<MediaType>
- getContentType(): Optional<MediaType>
- getCharacterEncoding(): Charset
- getLocale(): Optional<Locale>
- getMethod(): HttpMethod
- getUri(): URI
- getPath(): String
- initCharset(Charset): Charset
- createDecoder(String): QueryStringDecoder
- decodePath(String): String
- decodeParameters(String): NettyHttpParameters
- getMethodName(): String
- LastHttp2Content
-
NettyHttpHeaders
- nettyHeaders: HttpHeaders
- conversionService: ConversionService<ConversionService>
- NettyHttpHeaders(HttpHeaders, ConversionService): void
- NettyHttpHeaders(): void
- getNettyHeaders(): HttpHeaders
- contains(String): boolean
- setNettyHeaders(HttpHeaders): void
- get(CharSequence, ArgumentConversionContext<Object>): Optional<Object>
- isCollectionOrArray(Class<Object>): boolean
- getAll(CharSequence): List<String>
- names(): Set<String>
- values(): Collection<List<String>>
- get(CharSequence): String
- add(CharSequence, CharSequence): MutableHttpHeaders
- set(CharSequence, CharSequence): MutableHeaders
- remove(CharSequence): MutableHttpHeaders
-
NettyHttpParameters
- valuesMap: LinkedHashMap<CharSequence, List<String>>
- values: ConvertibleMultiValues<String>
- onChange: BiConsumer<CharSequence, List<String>>
- NettyHttpParameters(Map<String, List<String>>, ConversionService<ConversionService>, BiConsumer<CharSequence, List<String>>): void
- names(): Set<String>
- values(): Collection<List<String>>
- getAll(CharSequence): List<String>
- get(CharSequence): String
- get(CharSequence, ArgumentConversionContext<Object>): Optional<Object>
- add(CharSequence, List<CharSequence>): MutableHttpParameters
- NettyHttpRequestBuilder
- NettyHttpResponseBuilder
-
NettyMutableHttpResponse
- replace(ByteBuf): NettyMutableHttpResponse
- DEFAULT_SERVER_COOKIE_ENCODER: ServerCookieEncoder
- nettyResponse: FullHttpResponse
- headers: NettyHttpHeaders
- conversionService: ConversionService
- body: Object
- convertedBodies: Map<Class, Optional>
- attributes: MutableConvertibleValues<Object>
- serverCookieEncoder: ServerCookieEncoder
- NettyMutableHttpResponse(FullHttpResponse, ConversionService): void
- NettyMutableHttpResponse(ConversionService): void
- toString(): String
- getContentType(): Optional<MediaType>
- getHeaders(): MutableHttpHeaders
- getAttributes(): MutableConvertibleValues<Object>
- getStatus(): HttpStatus
- cookie(Cookie): MutableHttpResponse<Object>
- cookies(Set<Cookie>): MutableHttpResponse<Object>
- getBody(): Optional<Object>
- getBody(Class<Object>): Optional<Object>
- getBody(Argument<Object>): Optional<Object>
- status(HttpStatus, CharSequence): MutableHttpResponse<Object>
- getNativeResponse(): FullHttpResponse
- body(Object): MutableHttpResponse<Object>
- getServerCookieEncoder(): ServerCookieEncoder
- setServerCookieEncoder(ServerCookieEncoder): void
- toFullHttpResponse(): FullHttpResponse
- toStreamHttpResponse(): StreamedHttpResponse
- toHttpResponse(): HttpResponse
- isStream(): boolean
-
channel
-
ChannelPipelineCustomizer
- HANDLER_HTTP_COMPRESSOR: String
- HANDLER_HTTP_DECOMPRESSOR: String
- HANDLER_HTTP_KEEP_ALIVE: String
- HANDLER_HTTP_AGGREGATOR: String
- HANDLER_HTTP_CHUNK: String
- HANDLER_HTTP_STREAM: String
- HANDLER_HTTP_DECODER: String
- HANDLER_HTTP_PROXY: String
- HANDLER_HTTP_CLIENT_CODEC: String
- HANDLER_HTTP_SERVER_CODEC: String
- HANDLER_HTTP_CLIENT_INIT: String
- HANDLER_FLOW_CONTROL: String
- HANDLER_CONNECT_TTL: String
- HANDLER_IDLE_STATE: String
- HANDLER_MICRONAUT_WEBSOCKET_CLIENT: String
- HANDLER_SOCKS_5_PROXY: String
- HANDLER_MICRONAUT_FULL_HTTP_RESPONSE: String
- HANDLER_READ_TIMEOUT: String
- HANDLER_SSL: String
- HANDLER_MICRONAUT_SSE_EVENT_STREAM: String
- HANDLER_MICRONAUT_SSE_CONTENT: String
- HANDLER_MICRONAUT_HTTP_RESPONSE_STREAM: String
- HANDLER_MICRONAUT_HTTP_RESPONSE_FULL: String
- HANDLER_HTTP2_CONNECTION: String
- HANDLER_HTTP2_SETTINGS: String
- HANDLER_HTTP2_UPGRADE_REQUEST: String
- HANDLER_HTTP2_PROTOCOL_NEGOTIATOR: String
- HANDLER_WEBSOCKET_UPGRADE: String
- HANDLER_MICRONAUT_INBOUND: String
- HANDLER_ACCESS_LOGGER: String
- isClientChannel(): boolean
- isServerChannel(): boolean
- doOnConnect(ChannelPipelineListener): void
- ChannelPipelineListener
-
DefaultEventLoopGroupConfiguration
- numThreads: int
- ioRatio: Integer
- preferNativeTransport: boolean
- name: String
- executor: String
- shutdownQuietPeriod: Duration
- shutdownTimeout: Duration
- DefaultEventLoopGroupConfiguration(String, int, Integer, boolean, String, Duration, Duration): void
- DefaultEventLoopGroupConfiguration(): void
- getNumThreads(): int
- getIoRatio(): Optional<Integer>
- getExecutorName(): Optional<String>
- isPreferNativeTransport(): boolean
- getName(): String
- getShutdownQuietPeriod(): Duration
- getShutdownTimeout(): Duration
-
DefaultEventLoopGroupFactory
- useNativeTransport: boolean
- nativeFactory: EventLoopGroupFactory
- defaultFactory: EventLoopGroupFactory
- DefaultEventLoopGroupFactory(NioEventLoopGroupFactory, EventLoopGroupFactory): void
- setUseNativeTransport(Boolean): void
- createEventLoopGroup(EventLoopGroupConfiguration, ThreadFactory): EventLoopGroup
- createEventLoopGroup(int, Executor, Integer): EventLoopGroup
- createEventLoopGroup(int, ThreadFactory, Integer): EventLoopGroup
- serverSocketChannelClass(): Class<ServerSocketChannel>
- serverSocketChannelClass(EventLoopGroupConfiguration): Class<ServerSocketChannel>
- clientSocketChannelClass(EventLoopGroupConfiguration): Class<SocketChannel>
-
DefaultEventLoopGroupRegistry
- LOG: Logger
- eventLoopGroupFactory: EventLoopGroupFactory
- beanLocator: BeanLocator
- eventLoopGroups: Map<EventLoopGroup, EventLoopGroupConfiguration>
- DefaultEventLoopGroupRegistry(EventLoopGroupFactory, BeanLocator): void
- shutdown(): void
- eventLoopGroup(EventLoopGroupConfiguration): EventLoopGroup
- defaultEventLoopGroup(ThreadFactory): EventLoopGroup
- getDefaultEventLoopGroup(): EventLoopGroup
- getEventLoopGroup(String): Optional<EventLoopGroup>
- getEventLoopGroupConfiguration(String): Optional<EventLoopGroupConfiguration>
- EpollAvailabilityCondition
-
EpollEventLoopGroupFactory
- isNative(): boolean
- createEventLoopGroup(int, Integer): EventLoopGroup
- createEventLoopGroup(int, ThreadFactory, Integer): EventLoopGroup
- createEventLoopGroup(int, Executor, Integer): EventLoopGroup
- createEventLoopGroup(Integer): EventLoopGroup
- serverSocketChannelClass(): Class<ServerSocketChannel>
- clientSocketChannelClass(EventLoopGroupConfiguration): Class<SocketChannel>
-
EventLoopGroupConfiguration
- EVENT_LOOPS: String
- DEFAULT: String
- DEFAULT_LOOP: String
- DEFAULT_SHUTDOWN_QUIET_PERIOD: long
- DEFAULT_SHUTDOWN_TIMEOUT: long
- getNumThreads(): int
- getIoRatio(): Optional<Integer>
- getExecutorName(): Optional<String>
- isPreferNativeTransport(): boolean
- getShutdownQuietPeriod(): Duration
- getShutdownTimeout(): Duration
-
EventLoopGroupFactory
- NATIVE: String
- isNative(): boolean
- createEventLoopGroup(int, Executor, Integer): EventLoopGroup
- createEventLoopGroup(EventLoopGroupConfiguration, ThreadFactory): EventLoopGroup
- createEventLoopGroup(int, ThreadFactory, Integer): EventLoopGroup
- createEventLoopGroup(int, Integer): EventLoopGroup
- createEventLoopGroup(Integer): EventLoopGroup
- serverSocketChannelClass(): Class<ServerSocketChannel>
- serverSocketChannelClass(EventLoopGroupConfiguration): Class<ServerSocketChannel>
- clientSocketChannelClass(EventLoopGroupConfiguration): Class<SocketChannel>
- EventLoopGroupRegistry
- KQueueAvailabilityCondition
-
KQueueEventLoopGroupFactory
- createEventLoopGroup(int, Integer): EventLoopGroup
- createEventLoopGroup(int, ThreadFactory, Integer): EventLoopGroup
- createEventLoopGroup(int, Executor, Integer): EventLoopGroup
- createEventLoopGroup(Integer): EventLoopGroup
- isNative(): boolean
- serverSocketChannelClass(): Class<ServerSocketChannel>
- clientSocketChannelClass(EventLoopGroupConfiguration): Class<SocketChannel>
- NettyThreadFactory
-
NioEventLoopGroupFactory
- createEventLoopGroup(int, Integer): EventLoopGroup
- createEventLoopGroup(int, ThreadFactory, Integer): EventLoopGroup
- createEventLoopGroup(int, Executor, Integer): EventLoopGroup
- createEventLoopGroup(Integer): EventLoopGroup
- serverSocketChannelClass(): Class<ServerSocketChannel>
- clientSocketChannelClass(EventLoopGroupConfiguration): Class<SocketChannel>
- withIoRatio(NioEventLoopGroup, Integer): NioEventLoopGroup
- converters
-
ChannelPipelineCustomizer
- content
-
cookies
-
NettyCookie
- nettyCookie: Cookie
- NettyCookie(Cookie): void
- NettyCookie(String, String): void
- getNettyCookie(): Cookie
- getName(): String
- getValue(): String
- getDomain(): String
- getPath(): String
- isHttpOnly(): boolean
- isSecure(): boolean
- getMaxAge(): long
- maxAge(long): Cookie
- getSameSite(): Optional<SameSite>
- sameSite(SameSite): Cookie
- value(String): Cookie
- domain(String): Cookie
- path(String): Cookie
- secure(boolean): Cookie
- httpOnly(boolean): Cookie
- compareTo(Cookie): int
- NettyCookieFactory
-
NettyCookies
- conversionService: ConversionService<ConversionService>
- cookies: Map<CharSequence, Cookie>
- NettyCookies(String, HttpHeaders, ConversionService): void
- NettyCookies(HttpHeaders, ConversionService): void
- getAll(): Set<Cookie>
- findCookie(CharSequence): Optional<Cookie>
- get(CharSequence, Class<Object>): Optional<Object>
- get(CharSequence, ArgumentConversionContext<Object>): Optional<Object>
- values(): Collection<Cookie>
-
NettyCookie
- graal
-
reactive
- CancelledSubscriber
-
HandlerPublisher
- LOG: Logger
- COMPLETE: Object
- completed: AtomicBoolean
- executor: EventExecutor
- matcher: TypeParameterMatcher
- buffer: Queue<Object>
- hasSubscriber: AtomicBoolean
- state: State
- subscriber: Subscriber<Object>
- ctx: ChannelHandlerContext
- outstandingDemand: long
- noSubscriberError: Throwable
- HandlerPublisher(EventExecutor, Class<Object>): void
- subscribe(Subscriber<Object>): void
- acceptInboundMessage(Object): boolean
- cancelled(): void
- requestDemand(): void
- State
- provideSubscriber(Subscriber<Object>): void
- handlerAdded(ChannelHandlerContext): void
- channelRegistered(ChannelHandlerContext): void
- provideChannelContext(ChannelHandlerContext): void
- verifyRegisteredWithRightExecutor(): void
- channelActive(ChannelHandlerContext): void
- receivedCancel(): void
- channelRead(ChannelHandlerContext, Object): void
- messageForTrace(Object): Object
- publishMessage(Object): void
- channelInactive(ChannelHandlerContext): void
- handlerRemoved(ChannelHandlerContext): void
- complete(): void
- exceptionCaught(ChannelHandlerContext, Throwable): void
- closeIfNoSubscriber(): void
- cleanup(): void
- ChannelSubscription
-
HandlerSubscriber
- executor: EventExecutor
- hasSubscription: AtomicBoolean
- subscription: Subscription
- ctx: ChannelHandlerContext
- state: State
- lastWriteFuture: ChannelFuture
- HandlerSubscriber(EventExecutor): void
- error(Throwable): void
- complete(): void
- State
- handlerAdded(ChannelHandlerContext): void
- channelRegistered(ChannelHandlerContext): void
- channelWritabilityChanged(ChannelHandlerContext): void
- channelActive(ChannelHandlerContext): void
- channelInactive(ChannelHandlerContext): void
- handlerRemoved(ChannelHandlerContext): void
- exceptionCaught(ChannelHandlerContext, Throwable): void
- onSubscribe(Subscription): void
- onNext(Object): void
- onError(Throwable): void
- onComplete(): void
- doClose(): void
- maybeRequestMore(): void
- verifyRegisteredWithRightExecutor(ChannelHandlerContext): void
- cancel(): void
- provideSubscription(): void
- maybeStart(): void
- HotObservable
-
stream
- DefaultHttp2Content
- DefaultLastHttp2Content
-
DefaultStreamedHttpRequest
- stream: Publisher<HttpContent>
- consumed: boolean
- DefaultStreamedHttpRequest(HttpVersion, HttpMethod, String, Publisher<HttpContent>): void
- DefaultStreamedHttpRequest(HttpVersion, HttpMethod, String, boolean, Publisher<HttpContent>): void
- isConsumed(): boolean
- subscribe(Subscriber<Object>): void
- closeIfNoSubscriber(): void
- DefaultStreamedHttpResponse
-
DefaultWebSocketHttpResponse
- processor: Processor<WebSocketFrame, WebSocketFrame>
- handshakerFactory: WebSocketServerHandshakerFactory
- DefaultWebSocketHttpResponse(HttpVersion, HttpResponseStatus, Processor<WebSocketFrame, WebSocketFrame>, WebSocketServerHandshakerFactory): void
- DefaultWebSocketHttpResponse(HttpVersion, HttpResponseStatus, boolean, Processor<WebSocketFrame, WebSocketFrame>, WebSocketServerHandshakerFactory): void
- handshakerFactory(): WebSocketServerHandshakerFactory
- subscribe(Subscriber<Object>): void
- onSubscribe(Subscription): void
- onNext(WebSocketFrame): void
- onError(Throwable): void
- onComplete(): void
-
DelegateHttpMessage
- headers(): HttpHeaders
- setProtocolVersion(HttpVersion): HttpMessage
- message: HttpMessage
- DelegateHttpMessage(HttpMessage): void
- getProtocolVersion(): HttpVersion
- protocolVersion(): HttpVersion
- getDecoderResult(): DecoderResult
- decoderResult(): DecoderResult
- setDecoderResult(DecoderResult): void
- toString(): String
- DelegateHttpRequest
- DelegateHttpResponse
- DelegateStreamedHttpRequest
- DelegateStreamedHttpResponse
-
EmptyHttpRequest
- EmptyHttpRequest(HttpRequest): void
- setUri(String): FullHttpRequest
- setMethod(HttpMethod): FullHttpRequest
- setProtocolVersion(HttpVersion): FullHttpRequest
- copy(): FullHttpRequest
- retain(int): FullHttpRequest
- retain(): FullHttpRequest
- touch(): FullHttpRequest
- touch(Object): FullHttpRequest
- trailingHeaders(): HttpHeaders
- duplicate(): FullHttpRequest
- retainedDuplicate(): FullHttpRequest
- replace(ByteBuf): FullHttpRequest
- content(): ByteBuf
- refCnt(): int
- release(): boolean
- release(int): boolean
-
EmptyHttpResponse
- EmptyHttpResponse(HttpResponse): void
- setStatus(HttpResponseStatus): FullHttpResponse
- setProtocolVersion(HttpVersion): FullHttpResponse
- copy(): FullHttpResponse
- retain(int): FullHttpResponse
- retain(): FullHttpResponse
- touch(): FullHttpResponse
- touch(Object): FullHttpResponse
- trailingHeaders(): HttpHeaders
- duplicate(): FullHttpResponse
- retainedDuplicate(): FullHttpResponse
- replace(ByteBuf): FullHttpResponse
- content(): ByteBuf
- refCnt(): int
- release(): boolean
- release(int): boolean
- Http2Content
-
HttpStreamsClientHandler
- inFlight: int
- withServer: int
- closeOnZeroInFlight: ChannelPromise
- awaiting100Continue: Subscriber<HttpContent>
- awaiting100ContinueMessage: StreamedHttpMessage
- ignoreResponseBody: boolean
- HttpStreamsClientHandler(): void
- hasBody(HttpResponse): boolean
- close(ChannelHandlerContext, ChannelPromise): void
- consumedInMessage(ChannelHandlerContext): void
- receivedOutMessage(ChannelHandlerContext): void
- sentOutMessage(ChannelHandlerContext): void
- createEmptyMessage(HttpResponse): HttpResponse
- createStreamedMessage(HttpResponse, Publisher<HttpContent>): HttpResponse
- subscribeSubscriberToStream(StreamedHttpMessage, Subscriber<HttpContent>): void
- isClient(): boolean
- channelRead(ChannelHandlerContext, Object): void
- write(ChannelHandlerContext, Object, ChannelPromise): void
-
HttpStreamsHandler
- HANDLER_BODY_PUBLISHER: String
- LOG: Logger
- outgoing: Queue<Outgoing>
- inClass: Class<HttpMessage>
- outClass: Class<HttpMessage>
- currentlyStreamedMessage: HttpMessage
- ignoreBodyRead: boolean
- sendLastHttpContent: boolean
- HttpStreamsHandler(Class<HttpMessage>, Class<HttpMessage>): void
- hasBody(HttpMessage): boolean
- createEmptyMessage(HttpMessage): HttpMessage
- createStreamedMessage(HttpMessage, Publisher<HttpContent>): HttpMessage
- receivedInMessage(ChannelHandlerContext): void
- consumedInMessage(ChannelHandlerContext): void
- receivedOutMessage(ChannelHandlerContext): void
- sentOutMessage(ChannelHandlerContext): void
- subscribeSubscriberToStream(StreamedHttpMessage, Subscriber<HttpContent>): void
- bodyRequested(ChannelHandlerContext): void
- isClient(): boolean
- channelRead(ChannelHandlerContext, Object): void
- getStreamId(Object): int
- handleCancelled(ChannelHandlerContext, HttpMessage): void
- handleReadHttpContent(ChannelHandlerContext, HttpContent): void
- channelReadComplete(ChannelHandlerContext): void
- write(ChannelHandlerContext, Object, ChannelPromise): void
- unbufferedWrite(ChannelHandlerContext, Outgoing): void
- completeBody(ChannelHandlerContext): void
- removeHandlerIfActive(ChannelHandlerContext, String): void
- flushNext(ChannelHandlerContext): void
- executeInEventLoop(ChannelHandlerContext, Runnable): void
- isValidOutMessage(Object): boolean
- isValidInMessage(Object): boolean
- Outgoing
-
HttpStreamsServerHandler
- lastRequest: HttpRequest
- webSocketResponse: Outgoing
- inFlight: int
- continueExpected: boolean
- sendContinue: boolean
- close: boolean
- dependentHandlers: List<ChannelHandler>
- HttpStreamsServerHandler(): void
- HttpStreamsServerHandler(List<ChannelHandler>): void
- hasBody(HttpRequest): boolean
- createEmptyMessage(HttpRequest): HttpRequest
- createStreamedMessage(HttpRequest, Publisher<HttpContent>): HttpRequest
- channelRead(ChannelHandlerContext, Object): void
- receivedInMessage(ChannelHandlerContext): void
- sentOutMessage(ChannelHandlerContext): void
- unbufferedWrite(ChannelHandlerContext, Outgoing): void
- isValidOutMessage(Object): boolean
- canHaveBody(HttpResponse): boolean
- consumedInMessage(ChannelHandlerContext): void
- handleWebSocketResponse(ChannelHandlerContext, Outgoing): void
- bodyRequested(ChannelHandlerContext): void
- isClient(): boolean
- handlerRemoved(ChannelHandlerContext): void
- StreamedHttpMessage
- StreamedHttpRequest
- StreamedHttpResponse
-
StreamingInboundHttp2ToHttpAdapter
- connection: Http2Connection
- validateHttpHeaders: boolean
- maxContentLength: int
- messageKey: PropertyKey
- propagateSettings: boolean
- dataReadKey: PropertyKey
- StreamingInboundHttp2ToHttpAdapter(Http2Connection, int, boolean, boolean): void
- StreamingInboundHttp2ToHttpAdapter(Http2Connection, int): void
- removeMessage(Http2Stream): void
- getMessage(Http2Stream): HttpMessage
- putMessage(Http2Stream, HttpMessage): void
- onStreamRemoved(Http2Stream): void
- fireChannelRead(ChannelHandlerContext, HttpContent, Http2Stream): void
- fireChannelRead(ChannelHandlerContext, HttpMessage, Http2Stream): void
- newMessage(ChannelHandlerContext, Http2Stream, Http2Headers, boolean): HttpMessage
- processHeadersBegin(ChannelHandlerContext, Http2Stream, Http2Headers, boolean, boolean): HttpMessage
- processHeadersEnd(ChannelHandlerContext, Http2Stream, HttpMessage, boolean): void
- onDataRead(ChannelHandlerContext, int, ByteBuf, int, boolean): int
- getDataRead(Http2Stream): AtomicInteger
- onHeadersRead(ChannelHandlerContext, int, Http2Headers, int, boolean): void
- onHeadersRead(ChannelHandlerContext, int, Http2Headers, int, short, boolean, int, boolean): void
- onRstStreamRead(ChannelHandlerContext, int, long): void
- onPushPromiseRead(ChannelHandlerContext, int, int, Http2Headers, int): void
- onSettingsRead(ChannelHandlerContext, Http2Settings): void
- onRstStreamRead(Http2Stream, HttpMessage): void
- WebSocketHttpResponse
-
websocket
-
AbstractNettyWebSocketHandler
- ID: String
- LOG: Logger
- webSocketBinder: ArgumentBinderRegistry<WebSocketState>
- uriVariables: Map<String, Object>
- webSocketBean: WebSocketBean<Object>
- originatingRequest: HttpRequest<Object>
- messageHandler: MethodExecutionHandle<Object, Object>
- session: NettyRxWebSocketSession
- mediaTypeCodecRegistry: MediaTypeCodecRegistry
- webSocketVersion: WebSocketVersion
- webSocketSessionRepository: WebSocketSessionRepository
- bodyArgument: Argument<Object>
- closed: AtomicBoolean
- handleCloseReason(ChannelHandlerContext, CloseReason): void
- AbstractNettyWebSocketHandler(ChannelHandlerContext, RequestBinderRegistry, MediaTypeCodecRegistry, WebSocketBean<Object>, HttpRequest<Object>, Map<String, Object>, WebSocketVersion, WebSocketSessionRepository): void
- getBodyArgument(): Argument<Object>
- getSession(): NettyRxWebSocketSession
- exceptionCaught(ChannelHandlerContext, Throwable): void
- handlerRemoved(ChannelHandlerContext): void
- createWebSocketSession(ChannelHandlerContext): NettyRxWebSocketSession
- instrumentPublisher(ChannelHandlerContext, Object): Flowable<Object>
- invokeExecutable(BoundExecutable, MethodExecutionHandle<Object, Object>): Object
- channelRead0(ChannelHandlerContext, Object): void
- handleWebSocketFrame(ChannelHandlerContext, WebSocketFrame): void
- messageHandled(ChannelHandlerContext, NettyRxWebSocketSession, Object): void
- writeCloseFrameAndTerminate(ChannelHandlerContext, CloseReason): void
- handleCloseFrame(ChannelHandlerContext, CloseWebSocketFrame): void
- invokeAndClose(ChannelHandlerContext, Object, BoundExecutable, MethodExecutionHandle<Object, Object>, boolean): void
- bindMethod(HttpRequest<Object>, ArgumentBinderRegistry<WebSocketState>, MethodExecutionHandle<Object, Object>, List<Object>): BoundExecutable
- prepareBoundVariables(ExecutableMethod<Object, Object>, List<Object>): Map<Argument<Object>, Object>
- handleUnexpected(ChannelHandlerContext, Throwable): void
- writeCloseFrameAndTerminate(ChannelHandlerContext, int, String): void
-
NettyRxWebSocketSession
- WEB_SOCKET_SESSION_KEY: AttributeKey<NettyRxWebSocketSession>
- id: String
- channel: Channel
- request: HttpRequest<Object>
- protocolVersion: String
- isSecure: boolean
- codecRegistry: MediaTypeCodecRegistry
- attributes: MutableConvertibleValues<Object>
- messageEncoder: WebSocketMessageEncoder
- NettyRxWebSocketSession(String, Channel, HttpRequest<Object>, MediaTypeCodecRegistry, String, boolean): void
- getId(): String
- getAttributes(): MutableConvertibleValues<Object>
- isOpen(): boolean
- isWritable(): boolean
- isSecure(): boolean
- getOpenSessions(): Set<RxWebSocketSession>
- getRequestURI(): URI
- getRequestParameters(): ConvertibleMultiValues<String>
- getProtocolVersion(): String
- sendAsync(Object, MediaType): CompletableFuture<Object>
- sendSync(Object, MediaType): void
- send(Object, MediaType): Flowable<Object>
- close(): void
- close(CloseReason): void
- toString(): String
- put(CharSequence, Object): MutableConvertibleValues<Object>
- remove(CharSequence): MutableConvertibleValues<Object>
- clear(): MutableConvertibleValues<Object>
- names(): Set<String>
- values(): Collection<Object>
- get(CharSequence, ArgumentConversionContext<Object>): Optional<Object>
-
NettyServerWebSocketBroadcaster
- webSocketMessageEncoder: WebSocketMessageEncoder
- webSocketSessionRepository: WebSocketSessionRepository
- NettyServerWebSocketBroadcaster(WebSocketMessageEncoder, WebSocketSessionRepository): void
- broadcastSync(Object, MediaType, Predicate<WebSocketSession>): void
- broadcast(Object, MediaType, Predicate<WebSocketSession>): Flowable<Object>
- WebSocketMessageEncoder
- WebSocketSessionRepository
-
AbstractNettyWebSocketHandler
-
AbstractNettyHttpRequest
-
netty
-
http
-
micronaut