Skip to content

Commit 14e3baa

Browse files
committed
Merge branch 'main' into 2.0.x
2 parents 718c2af + 42449ff commit 14e3baa

File tree

3 files changed

+12
-12
lines changed

3 files changed

+12
-12
lines changed

README.md

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -78,8 +78,3 @@ For this reason, you should make sure you do one of the following:
7878

7979
In addition to raw reactive streams support, the `netty-reactive-streams-http` library provides some HTTP model abstractions and a handle for implementing HTTP servers/clients that use reactive streams to stream HTTP message bodies. The `HttpStreamsServerHandler` and `HttpStreamsClientHandler` ensure that every `HttpRequest` and `HttpResponse` in the pipeline is either a `FullHttpRequest` or `FullHttpResponse`, for when the body can be worked with in memory, or `StreamedHttpRequest` or `StreamedHttpResponse`, which are messages that double as `Publisher<HttpContent>` for handling the request/response body.
8080

81-
## Support
82-
83-
The Netty Reactive Streams library is *[Supported][]*.
84-
85-
[Supported]: https://developer.lightbend.com/docs/lightbend-platform/introduction/getting-help/support-terminology.html#supported

netty-reactive-streams-http/src/main/java/com/typesafe/netty/http/HttpStreamsServerHandler.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -113,6 +113,11 @@ protected void sentOutMessage(ChannelHandlerContext ctx) {
113113
if (close) {
114114
ctx.close();
115115
}
116+
117+
// release reference to lastRequest when there are no in flight requests so it can be GC'd
118+
if (inFlight == 0) {
119+
lastRequest = null;
120+
}
116121
}
117122

118123
@Override

pom.xml

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -84,11 +84,11 @@
8484
</dependencyManagement>
8585

8686
<properties>
87-
<netty.version>4.1.75.Final</netty.version>
88-
<reactive-streams.version>1.0.3</reactive-streams.version>
89-
<akka-stream.version>2.6.19</akka-stream.version>
90-
<maven-bundle-plugin.version>5.1.4</maven-bundle-plugin.version>
91-
<maven-jar-plugin.version>3.2.2</maven-jar-plugin.version>
87+
<netty.version>4.1.84.Final</netty.version>
88+
<reactive-streams.version>1.0.4</reactive-streams.version>
89+
<akka-stream.version>2.6.20</akka-stream.version>
90+
<maven-bundle-plugin.version>5.1.8</maven-bundle-plugin.version>
91+
<maven-jar-plugin.version>3.3.0</maven-jar-plugin.version>
9292
</properties>
9393

9494
<build>
@@ -105,7 +105,7 @@
105105
<plugin>
106106
<groupId>org.sonatype.plugins</groupId>
107107
<artifactId>nexus-staging-maven-plugin</artifactId>
108-
<version>1.6.12</version>
108+
<version>1.6.13</version>
109109
<extensions>true</extensions>
110110
<configuration>
111111
<serverId>ossrh</serverId>
@@ -172,7 +172,7 @@
172172
<plugin>
173173
<groupId>org.apache.maven.plugins</groupId>
174174
<artifactId>maven-javadoc-plugin</artifactId>
175-
<version>3.3.2</version>
175+
<version>3.4.1</version>
176176
<executions>
177177
<execution>
178178
<id>attach-javadocs</id>

0 commit comments

Comments
 (0)