@@ -102,7 +102,7 @@ public CompletableFuture<Messages.Response> dispatchRequest(Messages.Request req
         }
     }
 
-    private void initialize() {
+    protected void initialize() {
         // Register request handlers.
         // When there are multiple handlers registered for the same request, follow the rule "first register, first execute".
         registerHandler(new InitializeRequestHandler());
@@ -141,15 +141,15 @@ private void initialize() {
         registerHandlerForNoDebug(new ProcessIdHandler());
     }
 
-    private void registerHandlerForDebug(IDebugRequestHandler handler) {
+    protected void registerHandlerForDebug(IDebugRequestHandler handler) {
         registerHandler(requestHandlersForDebug, handler);
     }
 
-    private void registerHandlerForNoDebug(IDebugRequestHandler handler) {
+    protected void registerHandlerForNoDebug(IDebugRequestHandler handler) {
         registerHandler(requestHandlersForNoDebug, handler);
     }
 
-    private void registerHandler(IDebugRequestHandler handler) {
+    protected void registerHandler(IDebugRequestHandler handler) {
         registerHandler(requestHandlersForDebug, handler);
         registerHandler(requestHandlersForNoDebug, handler);
     }
@@ -165,4 +165,5 @@ private void registerHandler(Map<Command, List<IDebugRequestHandler>> requestHan
             handlerList.add(handler);
         }
     }
+
 }
@@ -0,0 +1,19 @@
+/*******************************************************************************
+ * Copyright (c) 2023 Microsoft Corporation and others.
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ *     Microsoft Corporation - initial API and implementation
+*******************************************************************************/
+
+package com.microsoft.java.debug.core.adapter;
+
+import com.microsoft.java.debug.core.protocol.IProtocolServer;
+
+@FunctionalInterface
+public interface IDebugAdapterFactory {
+    public IDebugAdapter create(IProtocolServer server);
+}
@@ -52,6 +52,20 @@ public ProtocolServer(InputStream input, OutputStream output, IProviderContext c
         debugAdapter = new DebugAdapter(this, context);
     }
 
+    /**
+     * Constructs a protocol server instance based on the given input stream and output stream.
+     * @param input
+     *              the input stream
+     * @param output
+     *              the output stream
+     * @param debugAdapterFactory
+     *              factory to create debug adapter that implements DAP communication
+     */
+    public ProtocolServer(InputStream input, OutputStream output, IDebugAdapterFactory debugAdapterFactory) {
+        super(input, output);
+        debugAdapter = debugAdapterFactory.create(this);
+    }
+
     /**
      * A while-loop to parse input data and send output data constantly.
      */
Original file line number	Diff line number	Diff line change
`@@ -102,7 +102,7 @@ public CompletableFuture<Messages.Response> dispatchRequest(Messages.Request req`
`102`	`102`	`}`
`103`	`103`	`}`
`104`	`104`
`105`		`- private void initialize() {`
	`105`	`+ protected void initialize() {`
`106`	`106`	`// Register request handlers.`
`107`	`107`	`// When there are multiple handlers registered for the same request, follow the rule "first register, first execute".`
`108`	`108`	`registerHandler(new InitializeRequestHandler());`
`@@ -141,15 +141,15 @@ private void initialize() {`
`141`	`141`	`registerHandlerForNoDebug(new ProcessIdHandler());`
`142`	`142`	`}`
`143`	`143`
`144`		`- private void registerHandlerForDebug(IDebugRequestHandler handler) {`
	`144`	`+ protected void registerHandlerForDebug(IDebugRequestHandler handler) {`
`145`	`145`	`registerHandler(requestHandlersForDebug, handler);`
`146`	`146`	`}`
`147`	`147`
`148`		`- private void registerHandlerForNoDebug(IDebugRequestHandler handler) {`
	`148`	`+ protected void registerHandlerForNoDebug(IDebugRequestHandler handler) {`
`149`	`149`	`registerHandler(requestHandlersForNoDebug, handler);`
`150`	`150`	`}`
`151`	`151`
`152`		`- private void registerHandler(IDebugRequestHandler handler) {`
	`152`	`+ protected void registerHandler(IDebugRequestHandler handler) {`
`153`	`153`	`registerHandler(requestHandlersForDebug, handler);`
`154`	`154`	`registerHandler(requestHandlersForNoDebug, handler);`
`155`	`155`	`}`
`@@ -165,4 +165,5 @@ private void registerHandler(Map<Command, List<IDebugRequestHandler>> requestHan`
`165`	`165`	`handlerList.add(handler);`
`166`	`166`	`}`
`167`	`167`	`}`
	`168`	`+`
`168`	`169`	`}`