allow for more base kernel reuse

Author: maxandersen

jjava-jupyter/src/main/java/org/dflib/jjava/jupyter/kernel/BaseKernel.java

@@ -364,7 +364,7 @@ protected void replaceOutputStreams(ShellReplyEnvironment env) {
         });
     }
 
-    private synchronized void handleExecuteRequest(ShellReplyEnvironment env, Message<ExecuteRequest> executeRequestMessage) {
+    protected synchronized void handleExecuteRequest(ShellReplyEnvironment env, Message<ExecuteRequest> executeRequestMessage) {
         commManager.setMessageContext(executeRequestMessage);
 
         ExecuteRequest request = executeRequestMessage.getContent();
@@ -398,7 +398,7 @@ private synchronized void handleExecuteRequest(ShellReplyEnvironment env, Messag
         }
     }
 
-    private void handleInspectRequest(ShellReplyEnvironment env, Message<InspectRequest> inspectRequestMessage) {
+    protected void handleInspectRequest(ShellReplyEnvironment env, Message<InspectRequest> inspectRequestMessage) {
         InspectRequest request = inspectRequestMessage.getContent();
         env.setBusyDeferIdle();
         try {
@@ -409,7 +409,7 @@ private void handleInspectRequest(ShellReplyEnvironment env, Message<InspectRequ
         }
     }
 
-    private void handleCompleteRequest(ShellReplyEnvironment env, Message<CompleteRequest> completeRequestMessage) {
+    protected void handleCompleteRequest(ShellReplyEnvironment env, Message<CompleteRequest> completeRequestMessage) {
         CompleteRequest request = completeRequestMessage.getContent();
         env.setBusyDeferIdle();
         try {
@@ -423,7 +423,7 @@ private void handleCompleteRequest(ShellReplyEnvironment env, Message<CompleteRe
         }
     }
 
-    private void handleHistoryRequest(ShellReplyEnvironment env, Message<HistoryRequest> historyRequestMessage) {
+    protected void handleHistoryRequest(ShellReplyEnvironment env, Message<HistoryRequest> historyRequestMessage) {
         // If the manager is unset, short circuit and skip this message
         HistoryManager manager = this.getHistoryManager();
         if (manager == null) {
@@ -459,7 +459,7 @@ private void handleHistoryRequest(ShellReplyEnvironment env, Message<HistoryRequ
         }
     }
 
-    private void handleIsCodeCompeteRequest(ShellReplyEnvironment env, Message<IsCompleteRequest> isCompleteRequestMessage) {
+    protected void handleIsCodeCompeteRequest(ShellReplyEnvironment env, Message<IsCompleteRequest> isCompleteRequestMessage) {
         IsCompleteRequest request = isCompleteRequestMessage.getContent();
         env.setBusyDeferIdle();
 
@@ -483,7 +483,7 @@ private void handleIsCodeCompeteRequest(ShellReplyEnvironment env, Message<IsCom
         env.reply(reply);
     }
 
-    private void handleKernelInfoRequest(ShellReplyEnvironment env, Message<KernelInfoRequest> kernelInfoRequestMessage) {
+    protected void handleKernelInfoRequest(ShellReplyEnvironment env, Message<KernelInfoRequest> kernelInfoRequestMessage) {
         env.setBusyDeferIdle();
         env.reply(new KernelInfoReply(
                         Header.PROTOCOL_VERISON,
@@ -496,7 +496,7 @@ private void handleKernelInfoRequest(ShellReplyEnvironment env, Message<KernelIn
         );
     }
 
-    private void handleShutdownRequest(ShellReplyEnvironment env, Message<ShutdownRequest> shutdownRequestMessage) {
+    protected void handleShutdownRequest(ShellReplyEnvironment env, Message<ShutdownRequest> shutdownRequestMessage) {
         ShutdownRequest request = shutdownRequestMessage.getContent();
         env.setBusyDeferIdle();
 
@@ -509,7 +509,7 @@ private void handleShutdownRequest(ShellReplyEnvironment env, Message<ShutdownRe
         env.markForShutdown();
     }
 
-    private void handleInterruptRequest(ShellReplyEnvironment env, Message<InterruptRequest> interruptRequestMessage) {
+    protected void handleInterruptRequest(ShellReplyEnvironment env, Message<InterruptRequest> interruptRequestMessage) {
         env.setBusyDeferIdle();
         env.defer().reply(new InterruptReply());
 

jjava-jupyter/src/main/java/org/dflib/jjava/jupyter/kernel/display/Renderer.java

@@ -122,7 +122,7 @@ public <T> void register(Set<MIMEType> supported, Set<MIMEType> preferred, Set<C
         }));
     }
 
-    private static DisplayData finalizeDisplayData(DisplayData data, Object value) {
+    protected DisplayData finalizeDisplayData(DisplayData data, Object value) {
         if (!data.hasDataForType(MIMEType.TEXT_PLAIN))
             data.putText(String.valueOf(value));