diff --git a/jjava-jupyter/src/main/java/org/dflib/jjava/jupyter/kernel/BaseKernel.java b/jjava-jupyter/src/main/java/org/dflib/jjava/jupyter/kernel/BaseKernel.java index 6dc9042..3e263d4 100644 --- a/jjava-jupyter/src/main/java/org/dflib/jjava/jupyter/kernel/BaseKernel.java +++ b/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 executeRequestMessage) { + protected synchronized void handleExecuteRequest(ShellReplyEnvironment env, Message 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 inspectRequestMessage) { + protected void handleInspectRequest(ShellReplyEnvironment env, Message inspectRequestMessage) { InspectRequest request = inspectRequestMessage.getContent(); env.setBusyDeferIdle(); try { @@ -409,7 +409,7 @@ private void handleInspectRequest(ShellReplyEnvironment env, Message completeRequestMessage) { + protected void handleCompleteRequest(ShellReplyEnvironment env, Message completeRequestMessage) { CompleteRequest request = completeRequestMessage.getContent(); env.setBusyDeferIdle(); try { @@ -423,7 +423,7 @@ private void handleCompleteRequest(ShellReplyEnvironment env, Message historyRequestMessage) { + protected void handleHistoryRequest(ShellReplyEnvironment env, Message 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 isCompleteRequestMessage) { + protected void handleIsCodeCompeteRequest(ShellReplyEnvironment env, Message isCompleteRequestMessage) { IsCompleteRequest request = isCompleteRequestMessage.getContent(); env.setBusyDeferIdle(); @@ -483,7 +483,7 @@ private void handleIsCodeCompeteRequest(ShellReplyEnvironment env, Message kernelInfoRequestMessage) { + protected void handleKernelInfoRequest(ShellReplyEnvironment env, Message kernelInfoRequestMessage) { env.setBusyDeferIdle(); env.reply(new KernelInfoReply( Header.PROTOCOL_VERISON, @@ -496,7 +496,7 @@ private void handleKernelInfoRequest(ShellReplyEnvironment env, Message shutdownRequestMessage) { + protected void handleShutdownRequest(ShellReplyEnvironment env, Message shutdownRequestMessage) { ShutdownRequest request = shutdownRequestMessage.getContent(); env.setBusyDeferIdle(); @@ -509,7 +509,7 @@ private void handleShutdownRequest(ShellReplyEnvironment env, Message interruptRequestMessage) { + protected void handleInterruptRequest(ShellReplyEnvironment env, Message interruptRequestMessage) { env.setBusyDeferIdle(); env.defer().reply(new InterruptReply()); diff --git a/jjava-jupyter/src/main/java/org/dflib/jjava/jupyter/kernel/display/Renderer.java b/jjava-jupyter/src/main/java/org/dflib/jjava/jupyter/kernel/display/Renderer.java index bccf649..ab7f2cd 100644 --- a/jjava-jupyter/src/main/java/org/dflib/jjava/jupyter/kernel/display/Renderer.java +++ b/jjava-jupyter/src/main/java/org/dflib/jjava/jupyter/kernel/display/Renderer.java @@ -122,7 +122,7 @@ public void register(Set supported, Set preferred, Set