chore: Fix compiling error in AsSubscriber.java and FromPublisher.java (

#953)
apache · Jan 15, 2024 · 057fe06 · 057fe06
1 parent c411fa5
commit 057fe06
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 9 deletions.
diff --git a/docs/src/test/java-jdk9-only/jdocs/stream/operators/source/AsSubscriber.java b/docs/src/test/java-jdk9-only/jdocs/stream/operators/source/AsSubscriber.java
@@ -22,9 +22,6 @@
 import org.apache.pekko.stream.javadsl.JavaFlowSupport;
 
 //#imports
-
-import org.apache.commons.lang.NotImplementedException;
-
 public interface AsSubscriber {
     // We are 'faking' the JavaFlowSupport API here so we can include the signature as a snippet in the API,
     // because we're not publishing those (jdk9+) classes in our API docs yet.
@@ -42,13 +39,13 @@ static <T> org.apache.pekko.stream.javadsl.Source<T, Subscriber<T>> asSubscriber
 
     static class Row {
         public String getField(String fieldName) {
-            throw new NotImplementedException();
+            throw new UnsupportedOperationException("Not implemented in sample");
         }
     }
 
     static class DatabaseClient {
         Publisher<Row> fetchRows() {
-            throw new NotImplementedException();
+            throw new UnsupportedOperationException("Not implemented in sample");
         }
     }
 

diff --git a/docs/src/test/java-jdk9-only/jdocs/stream/operators/source/FromPublisher.java b/docs/src/test/java-jdk9-only/jdocs/stream/operators/source/FromPublisher.java
@@ -22,8 +22,6 @@
 
 //#imports
 
-import org.apache.commons.lang.NotImplementedException;
-
 public interface FromPublisher {
     // We are 'faking' the JavaFlowSupport API here so we can include the signature as a snippet in the API,
     // because we're not publishing those (jdk9+) classes in our API docs yet.
@@ -41,13 +39,13 @@ static <T> org.apache.pekko.stream.javadsl.Source<T, NotUsed> fromPublisher(Publ
 
     static class Row {
         public String getField(String fieldName) {
-            throw new NotImplementedException();
+            throw new UnsupportedOperationException("Not implemented in sample");
         }
     }
 
     static class DatabaseClient {
         Publisher<Row> fetchRows() {
-            throw new NotImplementedException();
+            throw new UnsupportedOperationException("Not implemented in sample");
         }
     }