Tweaked readme - streamUsersById renamed

Author: bbakerman

README.md

@@ -299,7 +299,7 @@ A `org.dataloader.BatchPublisher` may be used to load this data:
         BatchPublisher<Long, User> batchPublisher = new BatchPublisher<Long, User>() {
             @Override
             public void load(List<Long> userIds, Subscriber<User> userSubscriber) {
-                Publisher<User> userResults = userManager.publishUsersById(userIds);
+                Publisher<User> userResults = userManager.streamUsersById(userIds);
                 userResults.subscribe(userSubscriber);
             }
         };
@@ -340,7 +340,7 @@ In instances like these, `org.dataloader.MappedBatchPublisher` can be used.
         MappedBatchPublisher<Long, User> mappedBatchPublisher = new MappedBatchPublisher<Long, User>() {
             @Override
             public void load(Set<Long> userIds, Subscriber<Map.Entry<Long, User>> userEntrySubscriber) {
-                Publisher<Map.Entry<Long, User>> userEntries = userManager.publishUsersById(userIds);
+                Publisher<Map.Entry<Long, User>> userEntries = userManager.streamUsersById(userIds);
                 userEntries.subscribe(userEntrySubscriber);
             }
         };

src/test/java/ReadmeExamples.java

@@ -19,7 +19,6 @@
 import org.dataloader.stats.ThreadLocalStatisticsCollector;
 import org.reactivestreams.Publisher;
 import org.reactivestreams.Subscriber;
-import reactor.core.publisher.Flux;
 
 import java.time.Duration;
 import java.util.ArrayList;
@@ -196,7 +195,7 @@ private void batchPublisher() {
         BatchPublisher<Long, User> batchPublisher = new BatchPublisher<Long, User>() {
             @Override
             public void load(List<Long> userIds, Subscriber<User> userSubscriber) {
-                Publisher<User> userResults = userManager.publishUsersById(userIds);
+                Publisher<User> userResults = userManager.streamUsersById(userIds);
                 userResults.subscribe(userSubscriber);
             }
         };
@@ -207,7 +206,7 @@ private void mappedBatchPublisher() {
         MappedBatchPublisher<Long, User> mappedBatchPublisher = new MappedBatchPublisher<Long, User>() {
             @Override
             public void load(Set<Long> userIds, Subscriber<Map.Entry<Long, User>> userEntrySubscriber) {
-                Publisher<Map.Entry<Long, User>> userEntries = userManager.publishUsersById(userIds);
+                Publisher<Map.Entry<Long, User>> userEntries = userManager.streamUsersById(userIds);
                 userEntries.subscribe(userEntrySubscriber);
             }
         };

src/test/java/org/dataloader/fixtures/UserManager.java

@@ -1,7 +1,6 @@
 package org.dataloader.fixtures;
 
 import org.reactivestreams.Publisher;
-import org.reactivestreams.Subscriber;
 import reactor.core.publisher.Flux;
 
 import java.util.HashMap;
@@ -56,11 +55,11 @@ public List<User> loadUsersById(List<Long> userIds) {
         return userIds.stream().map(this::loadUserById).collect(Collectors.toList());
     }
 
-    public Publisher<User> publishUsersById(List<Long> userIds) {
+    public Publisher<User> streamUsersById(List<Long> userIds) {
         return Flux.fromIterable(loadUsersById(userIds));
     }
 
-    public Publisher<Map.Entry<Long, User>> publishUsersById(Set<Long> userIds) {
+    public Publisher<Map.Entry<Long, User>> streamUsersById(Set<Long> userIds) {
         return Flux.fromIterable(loadMapOfUsersByIds(null, userIds).entrySet());
     }