[Git][java-team/netty-reactive-streams][upstream] 2 commits: New upstream version 2.0.7

Emmanuel Bourg (@ebourg) gitlab at salsa.debian.org
Mon Dec 5 22:17:28 GMT 2022 


Emmanuel Bourg pushed to branch upstream at Debian Java Maintainers / netty-reactive-streams


Commits:
20e26489 by Emmanuel Bourg at 2022-12-05T23:11:35+01:00
New upstream version 2.0.7
- - - - -
55579cd2 by Emmanuel Bourg at 2022-12-05T23:12:03+01:00
New upstream version 2.0.8
- - - - -


8 changed files:

- .github/workflows/ci.yml → .github/workflows/build-test.yml
- LICENSE.txt → LICENSE
- README.md
- netty-reactive-streams-http/pom.xml
- netty-reactive-streams-http/src/main/java/com/typesafe/netty/http/HttpStreamsServerHandler.java
- netty-reactive-streams/pom.xml
- netty-reactive-streams/src/main/java/com/typesafe/netty/HandlerPublisher.java
- pom.xml


Changes:

=====================================
.github/workflows/ci.yml → .github/workflows/build-test.yml
=====================================


=====================================
LICENSE.txt → LICENSE
=====================================


=====================================
README.md
=====================================
@@ -1,6 +1,16 @@
 # Netty Reactive Streams
 
-[![Build Status](https://travis-ci.org/playframework/netty-reactive-streams.svg?branch=2.0.x)](https://travis-ci.org/playframework/netty-reactive-streams)
+[![Twitter Follow](https://img.shields.io/twitter/follow/playframework?label=follow&style=flat&logo=twitter&color=brightgreen)](https://twitter.com/playframework)
+[![Discord](https://img.shields.io/discord/931647755942776882?logo=discord&logoColor=white)](https://discord.gg/g5s2vtZ4Fa)
+[![GitHub Discussions](https://img.shields.io/github/discussions/playframework/playframework?&logo=github&color=brightgreen)](https://github.com/playframework/playframework/discussions)
+[![StackOverflow](https://img.shields.io/static/v1?label=stackoverflow&logo=stackoverflow&logoColor=fe7a16&color=brightgreen&message=playframework)](https://stackoverflow.com/tags/playframework)
+[![YouTube](https://img.shields.io/youtube/channel/views/UCRp6QDm5SDjbIuisUpxV9cg?label=watch&logo=youtube&style=flat&color=brightgreen&logoColor=ff0000)](https://www.youtube.com/channel/UCRp6QDm5SDjbIuisUpxV9cg)
+[![Twitch Status](https://img.shields.io/twitch/status/playframework?logo=twitch&logoColor=white&color=brightgreen&label=live%20stream)](https://www.twitch.tv/playframework)
+[![OpenCollective](https://img.shields.io/opencollective/all/playframework?label=financial%20contributors&logo=open-collective)](https://opencollective.com/playframework)
+
+[![Build Status](https://github.com/playframework/netty-reactive-streams/actions/workflows/build-test.yml/badge.svg)](https://github.com/playframework/netty-reactive-streams/actions/workflows/build-test.yml)
+[![Maven](https://img.shields.io/maven-central/v/com.typesafe.netty/netty-reactive-streams.svg?logo=apache-maven)](https://mvnrepository.com/artifact/com.typesafe.netty/netty-reactive-streams)
+[![Repository size](https://img.shields.io/github/repo-size/playframework/netty-reactive-streams.svg?logo=git)](https://github.com/playframework/netty-reactive-streams)
 
 This provides a reactive streams implementation for Netty.  Essentially it comes in the form of two channel handlers, one that publishes inbound messages received on a channel to a `Publisher`, and another that writes messages received by a `Subscriber` outbound.
 
@@ -68,8 +78,3 @@ For this reason, you should make sure you do one of the following:
 
 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.
 
-## Support
-
-The Netty Reactive Streams library is *[Supported][]*.
-
-[Supported]: https://developer.lightbend.com/docs/lightbend-platform/introduction/getting-help/support-terminology.html#supported


=====================================
netty-reactive-streams-http/pom.xml
=====================================
@@ -5,7 +5,7 @@
     <parent>
         <groupId>com.typesafe.netty</groupId>
         <artifactId>netty-reactive-streams-parent</artifactId>
-        <version>2.0.6</version>
+        <version>2.0.9-SNAPSHOT</version>
     </parent>
 
     <artifactId>netty-reactive-streams-http</artifactId>


=====================================
netty-reactive-streams-http/src/main/java/com/typesafe/netty/http/HttpStreamsServerHandler.java
=====================================
@@ -113,6 +113,11 @@ public class HttpStreamsServerHandler extends HttpStreamsHandler<HttpRequest, Ht
         if (close) {
             ctx.close();
         }
+
+        // release reference to lastRequest when there are no in flight requests so it can be GC'd
+        if (inFlight == 0) {
+            lastRequest = null;
+        }
     }
 
     @Override


=====================================
netty-reactive-streams/pom.xml
=====================================
@@ -5,7 +5,7 @@
     <parent>
         <groupId>com.typesafe.netty</groupId>
         <artifactId>netty-reactive-streams-parent</artifactId>
-        <version>2.0.6</version>
+        <version>2.0.9-SNAPSHOT</version>
     </parent>
 
     <artifactId>netty-reactive-streams</artifactId>


=====================================
netty-reactive-streams/src/main/java/com/typesafe/netty/HandlerPublisher.java
=====================================
@@ -405,7 +405,9 @@ public class HandlerPublisher<T> extends ChannelDuplexHandler implements Publish
                 break;
             case DEMANDING:
             case IDLE:
-                subscriber.onComplete();
+                if (subscriber != null) {
+                    subscriber.onComplete();
+                }
                 state = DONE;
                 break;
             case NO_SUBSCRIBER_ERROR:


=====================================
pom.xml
=====================================
@@ -4,7 +4,7 @@
 
     <groupId>com.typesafe.netty</groupId>
     <artifactId>netty-reactive-streams-parent</artifactId>
-    <version>2.0.6</version>
+    <version>2.0.9-SNAPSHOT</version>
 
     <name>Netty Reactive Streams Parent POM</name>
     <description>Reactive streams implementation for Netty.</description>
@@ -84,11 +84,11 @@
     </dependencyManagement>
 
     <properties>
-        <netty.version>4.1.75.Final</netty.version>
-        <reactive-streams.version>1.0.3</reactive-streams.version>
-        <akka-stream.version>2.6.19</akka-stream.version>
-        <maven-bundle-plugin.version>5.1.4</maven-bundle-plugin.version>
-        <maven-jar-plugin.version>3.2.2</maven-jar-plugin.version>
+        <netty.version>4.1.84.Final</netty.version>
+        <reactive-streams.version>1.0.4</reactive-streams.version>
+        <akka-stream.version>2.6.20</akka-stream.version>
+        <maven-bundle-plugin.version>5.1.8</maven-bundle-plugin.version>
+        <maven-jar-plugin.version>3.3.0</maven-jar-plugin.version>
     </properties>
 
     <build>
@@ -105,7 +105,7 @@
           <plugin>
               <groupId>org.sonatype.plugins</groupId>
               <artifactId>nexus-staging-maven-plugin</artifactId>
-              <version>1.6.12</version>
+              <version>1.6.13</version>
               <extensions>true</extensions>
               <configuration>
                   <serverId>ossrh</serverId>
@@ -172,7 +172,7 @@
                     <plugin>
                         <groupId>org.apache.maven.plugins</groupId>
                         <artifactId>maven-javadoc-plugin</artifactId>
-                        <version>3.3.2</version>
+                        <version>3.4.1</version>
                         <executions>
                             <execution>
                                 <id>attach-javadocs</id>
@@ -205,7 +205,7 @@
         <connection>scm:git:https://github.com/playframework/netty-reactive-streams.git</connection>
         <developerConnection>scm:git:git at github.com:playframework/netty-reactive-streams.git</developerConnection>
         <url>https://github.com/playframework/netty-reactive-streams</url>
-        <tag>netty-reactive-streams-parent-2.0.6</tag>
+        <tag>HEAD</tag>
     </scm>
 
     <distributionManagement>



View it on GitLab: https://salsa.debian.org/java-team/netty-reactive-streams/-/compare/b13985e8b17a75faeff597857f6326610ee2def0...55579cd241666c4bcc1b5c1c98bef196f27929fc

-- 
View it on GitLab: https://salsa.debian.org/java-team/netty-reactive-streams/-/compare/b13985e8b17a75faeff597857f6326610ee2def0...55579cd241666c4bcc1b5c1c98bef196f27929fc
You're receiving this email because of your account on salsa.debian.org.


-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://alioth-lists.debian.net/pipermail/pkg-java-commits/attachments/20221205/c4501c48/attachment.htm>

More information about the pkg-java-commits mailing list