Add requireNonNull for listener objects

deephaven · Aug 15, 2024 · b4751f1 · b4751f1
1 parent eb454aa
commit b4751f1
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/Integrations/src/main/java/io/deephaven/integrations/python/PythonMergedListenerAdapter.java b/Integrations/src/main/java/io/deephaven/integrations/python/PythonMergedListenerAdapter.java
@@ -59,7 +59,7 @@ private PythonMergedListenerAdapter(
             @NotNull PyObject pyOnFailureCallback) {
         super(Arrays.asList(recorders), Arrays.asList(dependencies), listenerDescription, null);
         Arrays.stream(recorders).forEach(rec -> rec.setMergedListener(this));
-        this.pyListenerCallable = PythonUtils.pyMergeListenerFunc(pyListener);
+        this.pyListenerCallable = PythonUtils.pyMergeListenerFunc(Objects.requireNonNull(pyListener));
         this.pyOnFailureCallback = Objects.requireNonNull(pyOnFailureCallback);
     }
 

diff --git a/Integrations/src/main/java/io/deephaven/integrations/python/PythonReplayListenerAdapter.java b/Integrations/src/main/java/io/deephaven/integrations/python/PythonReplayListenerAdapter.java
@@ -77,7 +77,7 @@ private PythonReplayListenerAdapter(
             @Nullable NotificationQueue.Dependency... dependencies) {
         super(description, source, retain);
         this.dependencies = dependencies;
-        this.pyListenerCallable = PythonUtils.pyListenerFunc(pyListener);
+        this.pyListenerCallable = Objects.requireNonNull(PythonUtils.pyListenerFunc(pyListener));
         this.pyOnFailureCallback = Objects.requireNonNull(pyOnFailureCallback);
     }