Merge pull request #75 from otaviojava/small_improvements

Small improvements

Author: jroper

messaging/tck/src/main/java/org/eclipse/microprofile/reactive/messaging/tck/framework/MockedSender.java

@@ -65,7 +65,7 @@ public PublisherBuilder<T> createPublisher() {
     }
 
     public void send(T... message) {
-        queue.addAll(Arrays.asList(message).stream().map(SimpleMessage::new).collect(Collectors.toList()));
+        queue.addAll(Arrays.stream(message).map(SimpleMessage::new).collect(Collectors.toList()));
         trySend();
     }
 

streams/api/src/main/java/org/eclipse/microprofile/reactive/streams/ReactiveStreams.java

@@ -25,6 +25,7 @@
 import org.reactivestreams.Subscriber;
 
 import java.util.Arrays;
+import java.util.Collections;
 import java.util.function.Supplier;
 import java.util.function.UnaryOperator;
 import java.util.stream.Stream;
@@ -59,7 +60,7 @@ public static <T> PublisherBuilder<T> fromPublisher(Publisher<? extends T> publi
      * @return A publisher builder that will emit the element.
      */
     public static <T> PublisherBuilder<T> of(T t) {
-        return new PublisherBuilder<>(new Stage.Of(Arrays.asList(t)));
+        return new PublisherBuilder<>(new Stage.Of(Collections.singletonList(t)));
     }
 
     /**

streams/tck/src/main/java/org/eclipse/microprofile/reactive/streams/tck/CancelStageVerification.java

@@ -25,7 +25,7 @@
 import org.testng.SkipException;
 import org.testng.annotations.Test;
 
-import java.util.Arrays;
+import java.util.Collections;
 import java.util.List;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.CompletionStage;
@@ -54,7 +54,7 @@ public void cancel() {
 
     @Override
     List<Object> reactiveStreamsTckVerifiers() {
-        return Arrays.asList(new SubscriberVerification());
+        return Collections.singletonList(new SubscriberVerification());
     }
 
     public class SubscriberVerification extends StageSubscriberBlackboxVerification {