Minor cleanup

Author: rmichela

pom.xml

@@ -70,7 +70,7 @@
  <canteen.plugin.version>1.1.0</canteen.plugin.version>
 
  <!-- Dependency Versions -->
- <reactive.streams.version>1.0.3</reactive.streams.version>
+ <reactive.streams.version>1.0.4</reactive.streams.version>
  <grpc.version>1.42.1</grpc.version>
  <protoc.version>3.19.1</protoc.version> <!-- Same version as grpc-proto -->
  <jprotoc.version>1.2.0</jprotoc.version>

reactor/reactor-grpc-stub/pom.xml

@@ -67,19 +67,6 @@
  <artifactId>mockito-core</artifactId>
  <scope>test</scope>
  </dependency>
- <!-- https://mvnrepository.com/artifact/org.slf4j/slf4j-api -->
- <dependency>
- <groupId>org.slf4j</groupId>
- <artifactId>slf4j-api</artifactId>
- <version>1.7.36</version>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>ch.qos.logback</groupId>
- <artifactId>logback-classic</artifactId>
- <version>1.2.10</version>
- <scope>test</scope>
- </dependency>
  </dependencies>
 
  <build>

reactor/reactor-grpc-stub/src/test/java/com/salesforce/reactorgrpc/stub/ReactorClientStreamObserverAndPublisherTest.java

@@ -7,8 +7,6 @@
 package com.salesforce.reactorgrpc.stub;
 
 import org.junit.jupiter.api.Test;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 import reactor.core.Fuseable;
 import reactor.core.publisher.Flux;
 import reactor.core.scheduler.Schedulers;
@@ -22,7 +20,6 @@
 
 
 public class ReactorClientStreamObserverAndPublisherTest {
- private static final Logger log = LoggerFactory.getLogger(ReactorClientStreamObserverAndPublisherTest.class.getName());
 
  private static final int DEFAULT_CHUNK_SIZE = 512;
  private static final int PART_OF_CHUNK = DEFAULT_CHUNK_SIZE * 2 / 3;
@@ -76,18 +73,12 @@ public void discardQueueTest() {
  AtomicBoolean firstHandled = new AtomicBoolean();
  Flux<Integer> consumer =
  Flux.from(processor)
- .doOnDiscard(Integer.class, i -> {
- log.info("Processor: discarding {}", i);
- discardedByObserverAndPublisher.add(i);
- })
+ .doOnDiscard(Integer.class, discardedByObserverAndPublisher::add)
  .log("processor")
  .limitRate(1)
  .publishOn(Schedulers.parallel())
  .limitRate(1)
- .doOnDiscard(Integer.class, i -> {
- log.info("publishOn: discarding {}", i);
- discardedByPublishOn.add(i);
- })
+ .doOnDiscard(Integer.class, discardedByPublishOn::add)
  .<Integer>handle((i, sink) -> {
  if (firstHandled.compareAndSet(false, true)) {
  try {