[Git][java-team/netty-reactive-streams][upstream] 3 commits: New upstream version 2.0.2
Emmanuel Bourg
gitlab at salsa.debian.org
Thu Sep 10 15:06:10 BST 2020
Emmanuel Bourg pushed to branch upstream at Debian Java Maintainers / netty-reactive-streams
Commits:
703dbe16 by Emmanuel Bourg at 2020-09-10T15:58:33+02:00
New upstream version 2.0.2
- - - - -
c1d09356 by Emmanuel Bourg at 2020-09-10T15:58:41+02:00
New upstream version 2.0.3
- - - - -
e04b2a97 by Emmanuel Bourg at 2020-09-10T15:58:48+02:00
New upstream version 2.0.4
- - - - -
8 changed files:
- .travis.yml
- README.md
- netty-reactive-streams-http/pom.xml
- netty-reactive-streams-http/src/test/java/com/typesafe/netty/http/FullStackHttpIdentityProcessorVerificationTest.java
- netty-reactive-streams-http/src/test/java/com/typesafe/netty/http/HttpStreamsTest.java
- netty-reactive-streams-http/src/test/java/com/typesafe/netty/http/WebSocketsTest.java
- netty-reactive-streams/pom.xml
- pom.xml
Changes:
=====================================
.travis.yml
=====================================
@@ -1,11 +1,13 @@
language: java
-dist: trusty
-sudo: false
-group: beta
-jdk:
- - oraclejdk8
+
+env:
+ - TRAVIS_JDK=8
+ - TRAVIS_JDK=11
+
+before_install: curl -Ls https://git.io/jabba | bash && . ~/.jabba/jabba.sh
+install: jabba install "adopt@~1.$TRAVIS_JDK.0-0" && jabba use "$_" && java -Xmx32m -version
+
cache:
directories:
+ - $HOME/.jabba/jdk
- $HOME/.m2
-after_success:
- - bash <(curl -s https://codecov.io/bash)
\ No newline at end of file
=====================================
README.md
=====================================
@@ -1,6 +1,6 @@
# Netty Reactive Streams
-[](https://travis-ci.org/playframework/netty-reactive-streams) [](https://codecov.io/github/playframework/netty-reactive-streams?branch=master)
+[](https://travis-ci.org/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.
@@ -67,3 +67,9 @@ For this reason, you should make sure you do one of the following:
## Netty Reactive Streams HTTP
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.1</version>
+ <version>2.0.4</version>
</parent>
<artifactId>netty-reactive-streams-http</artifactId>
=====================================
netty-reactive-streams-http/src/test/java/com/typesafe/netty/http/FullStackHttpIdentityProcessorVerificationTest.java
=====================================
@@ -3,7 +3,6 @@ package com.typesafe.netty.http;
import akka.NotUsed;
import akka.actor.ActorSystem;
import akka.japi.function.Function;
-import akka.stream.ActorMaterializer;
import akka.stream.Materializer;
import akka.stream.javadsl.*;
import io.netty.channel.*;
@@ -20,7 +19,11 @@ import scala.concurrent.duration.Duration;
import java.net.InetSocketAddress;
import java.util.ArrayList;
import java.util.List;
-import java.util.concurrent.*;
+import java.util.concurrent.Callable;
+import java.util.concurrent.CompletionStage;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.TimeUnit;
/**
* This identity processor verification verifies a client making requests to a server, that echos the
@@ -52,7 +55,7 @@ public class FullStackHttpIdentityProcessorVerificationTest extends IdentityProc
public void start() throws Exception {
executorService = Executors.newCachedThreadPool();
actorSystem = ActorSystem.create();
- materializer = ActorMaterializer.create(actorSystem);
+ materializer = Materializer.matFromSystem(actorSystem);
helper = new HttpHelper(materializer);
eventLoop = new NioEventLoopGroup();
ProcessorHttpServer server = new ProcessorHttpServer(eventLoop);
=====================================
netty-reactive-streams-http/src/test/java/com/typesafe/netty/http/HttpStreamsTest.java
=====================================
@@ -2,7 +2,6 @@ package com.typesafe.netty.http;
import akka.actor.ActorSystem;
import akka.japi.function.Function;
-import akka.stream.ActorMaterializer;
import akka.stream.Materializer;
import akka.stream.javadsl.Flow;
import com.typesafe.netty.HandlerPublisher;
@@ -16,7 +15,6 @@ import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import io.netty.channel.socket.nio.NioSocketChannel;
import io.netty.handler.codec.http.*;
-import org.omg.CORBA.TIMEOUT;
import org.reactivestreams.Processor;
import org.testng.annotations.AfterClass;
import org.testng.annotations.AfterMethod;
@@ -344,7 +342,7 @@ public class HttpStreamsTest {
public void startEventLoop() {
eventLoop = new NioEventLoopGroup();
actorSystem = ActorSystem.create();
- materializer = ActorMaterializer.create(actorSystem);
+ materializer = Materializer.matFromSystem(actorSystem);
helper = new HttpHelper(materializer);
}
=====================================
netty-reactive-streams-http/src/test/java/com/typesafe/netty/http/WebSocketsTest.java
=====================================
@@ -2,7 +2,6 @@ package com.typesafe.netty.http;
import akka.actor.ActorSystem;
import akka.japi.function.Function;
-import akka.stream.ActorMaterializer;
import akka.stream.Materializer;
import akka.stream.javadsl.Flow;
import io.netty.bootstrap.Bootstrap;
@@ -146,7 +145,7 @@ public class WebSocketsTest {
public void startEventLoop() {
eventLoop = new NioEventLoopGroup();
actorSystem = ActorSystem.create();
- materializer = ActorMaterializer.create(actorSystem);
+ materializer = Materializer.matFromSystem(actorSystem);
}
@AfterClass
=====================================
netty-reactive-streams/pom.xml
=====================================
@@ -5,7 +5,7 @@
<parent>
<groupId>com.typesafe.netty</groupId>
<artifactId>netty-reactive-streams-parent</artifactId>
- <version>2.0.1</version>
+ <version>2.0.4</version>
</parent>
<artifactId>netty-reactive-streams</artifactId>
=====================================
pom.xml
=====================================
@@ -4,7 +4,7 @@
<groupId>com.typesafe.netty</groupId>
<artifactId>netty-reactive-streams-parent</artifactId>
- <version>2.0.1</version>
+ <version>2.0.4</version>
<name>Netty Reactive Streams Parent POM</name>
<description>Reactive streams implementation for Netty.</description>
@@ -20,7 +20,7 @@
<licenses>
<license>
- <name>Apache 2</name>
+ <name>Apache License, Version 2.0</name>
<url>http://www.apache.org/licenses/LICENSE-2.0.txt</url>
<distribution>repo</distribution>
</license>
@@ -71,7 +71,7 @@
<dependency>
<groupId>org.testng</groupId>
<artifactId>testng</artifactId>
- <version>6.10</version>
+ <version>7.0.0</version>
<scope>test</scope>
</dependency>
<dependency>
@@ -84,9 +84,11 @@
</dependencyManagement>
<properties>
- <netty.version>4.1.13.Final</netty.version>
- <reactive-streams.version>1.0.0</reactive-streams.version>
- <akka-stream.version>2.5.3</akka-stream.version>
+ <netty.version>4.1.43.Final</netty.version>
+ <reactive-streams.version>1.0.3</reactive-streams.version>
+ <akka-stream.version>2.6.0</akka-stream.version>
+ <maven-bundle-plugin.version>3.5.1</maven-bundle-plugin.version>
+ <maven-jar-plugin.version>3.1.0</maven-jar-plugin.version>
</properties>
<build>
@@ -94,7 +96,7 @@
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
- <version>3.6.1</version>
+ <version>3.8.1</version>
<configuration>
<source>1.7</source>
<target>1.7</target>
@@ -103,7 +105,7 @@
<plugin>
<groupId>org.sonatype.plugins</groupId>
<artifactId>nexus-staging-maven-plugin</artifactId>
- <version>1.6.3</version>
+ <version>1.6.7</version>
<extensions>true</extensions>
<configuration>
<serverId>ossrh</serverId>
@@ -123,26 +125,31 @@
</configuration>
</plugin>
<plugin>
- <groupId>org.jacoco</groupId>
- <artifactId>jacoco-maven-plugin</artifactId>
- <version>0.7.6.201602180812</version>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-jar-plugin</artifactId>
+ <version>${maven-jar-plugin.version}</version>
+ <configuration>
+ <archive>
+ <manifestFile>${project.build.outputDirectory}/META-INF/MANIFEST.MF</manifestFile>
+ </archive>
+ </configuration>
+ </plugin>
+ <plugin>
+ <groupId>org.apache.felix</groupId>
+ <artifactId>maven-bundle-plugin</artifactId>
+ <version>${maven-bundle-plugin.version}</version>
<executions>
<execution>
+ <id>bundle-manifest</id>
+ <phase>process-classes</phase>
<goals>
- <goal>prepare-agent</goal>
- </goals>
- </execution>
- <execution>
- <id>report</id>
- <phase>test</phase>
- <goals>
- <goal>report</goal>
+ <goal>manifest</goal>
</goals>
</execution>
</executions>
</plugin>
</plugins>
- </build>
+ </build>
<profiles>
<profile>
@@ -195,10 +202,10 @@
</profiles>
<scm>
- <connection>scm:git://github.com/playframework/netty-reactive-streams.git</connection>
+ <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>scm:git://github.com/playframework/netty-reactive-streams.git</url>
- <tag>netty-reactive-streams-parent-2.0.1</tag>
+ <url>https://github.com/playframework/netty-reactive-streams</url>
+ <tag>netty-reactive-streams-parent-2.0.4</tag>
</scm>
<distributionManagement>
View it on GitLab: https://salsa.debian.org/java-team/netty-reactive-streams/-/compare/84a09f22582eb8a5408d9f5bf6718591ee4c8eed...e04b2a97643cba7b83b86fe01d9ca6921fb83298
--
View it on GitLab: https://salsa.debian.org/java-team/netty-reactive-streams/-/compare/84a09f22582eb8a5408d9f5bf6718591ee4c8eed...e04b2a97643cba7b83b86fe01d9ca6921fb83298
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/20200910/168f3c2c/attachment.html>
More information about the pkg-java-commits
mailing list