[cassandra-accord] 05/15: onNext now is allowed to throw checked exception

[dcapwell]

This is an automated email from the ASF dual-hosted git repository.

dcapwell pushed a commit to branch CASSANDRA-18519
in repository https://gitbox.apache.org/repos/asf/cassandra-accord.git

commit 856127f6a3012fa4529c1053f1cae7bf0ee24ac9
Author: David Capwell <dcapw...@gmail.com>
AuthorDate: Thu May 11 13:40:41 2023 -0700

    onNext now is allowed to throw checked exception
---
 accord-core/src/main/java/accord/utils/async/Observable.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/accord-core/src/main/java/accord/utils/async/Observable.java 
b/accord-core/src/main/java/accord/utils/async/Observable.java
index bcf9695a..00986e6b 100644
--- a/accord-core/src/main/java/accord/utils/async/Observable.java
+++ b/accord-core/src/main/java/accord/utils/async/Observable.java
@@ -29,7 +29,7 @@ import java.util.function.Function;
  */
 public interface Observable<T>
 {
-    void onNext(T value);
+    void onNext(T value) throws Exception;
     default void onError(Throwable t) {}
     default void onCompleted() {}
 
@@ -41,7 +41,7 @@ public interface Observable<T>
         return new Observable<R>()
         {
             @Override
-            public void onNext(R value)
+            public void onNext(R value) throws Exception
             {
                 self.onNext(mapper.apply(value));
             }


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org
For additional commands, e-mail: commits-h...@cassandra.apache.org