injae kim

Provide a way to adapt `StreamWriter` into `OutputStream`

5

**Related Issue** #3092 ### Motivation: ```java StreamMessageWriter reactive = ,,,; OutputStream out = reactive.asOutputStream(); objectMapper.writeValue(out, myJsonObject); ``` - I want to provide a way to adapt `StreamMessage` into `InputStream` and...

Add `StreamMessage.fromOutputStream()`

8

**Related Issue** #3092 ### Motivation: ```java public HttpResponse serve(...) { var stream = StreaMessage.fromOutputStream(this:startBlockingService); return HttpRsponse.builder(headers) .content(stream) .build() } private void startBlockingService(OutputStream os) { // perform blocking operation var data0...

Fixes gh-752, gh-1668 ### Motivation ``` The API I need to apply a rate limiter for, is using the "Fixed window counter" algorithm. Let's say it allows 10 requests each...

[WIP] Introduce `CompositeHttpHeadersBase` to replace HttpHeadersUtil.merge()

4

related issue: https://github.com/line/armeria/issues/5146 ### Motivation: https://github.com/line/armeria/blob/3595dacd9e7675fec309a1029a2a97b829c08682/core/src/main/java/com/linecorp/armeria/internal/common/HttpHeadersUtil.java#L46-L46 - On https://github.com/line/armeria/issues/5146, we found that `HttpHeadersUtil.mergeHeaders(..)` occupies a large part of CPU cycles due to expensive deep-copy operations ### 📌 PRs Overview: 1....

Set RequestContext.isTimedOut(true) on DNS, session, write timeout

7

Related issue #4935 ### Motivation: ``` We need to make sure CancellationScheduler.finishNow(TimeoutException) is invoked on more timeout types, such as session/connection/DNS timeout so that true is set to ctx.isTimedOut(). ```...

Fixes #2316 ### Motivation https://github.com/spring-cloud/spring-cloud-gateway/blob/fb3b782afc40db9c220667ff8cc52d4968075099/spring-cloud-gateway-server/src/main/java/org/springframework/cloud/gateway/filter/factory/TokenRelayGatewayFilterFactory.java#L63-L64 - On `TokenRelayGatewayFilterFactory`, we found that it always fetches the access token via the the refresh token which is stored within the current users session...

Support sending large STOMP messages as fragmented frames on `WebSocketStompClient`

2

Closes gh-29354 ### Motivation - By https://github.com/spring-projects/spring-framework/issues/16152, we already added handling of fragmented STOMP frames `receiving` by `BufferingStompDecoder` like other stomp libraries (e.g. [stomp-websocket.js](https://github.com/jmesnil/stomp-websocket/commit/2db3451bfc0e4f950bd5bf47568ae660a1454a67)) - But we not added handling...

related issue #4412 ### Motivation: - On #4412, we found that `PatternMatchingCompositeLineMapper` doesn't support regular expression matching - It only supports `AntPathMatcher` style matching now ### Modification: - Support full...

related issue #4384 ### Motivation: ``` Chunk listeners are not designed to throw exceptions. Exceptions must be handled in the implementation or the step will terminate. This is mentioned in...

Add AsyncLoader to load and update value periodically

2

Fixes #5506. ### Motivation: `AsyncLoader` can be useful in the following situations. - When it is necessary to periodically read and update information from a file such as resolv.conf ....