@@ -39,6 +39,17 @@ export class EmbeddedKernel extends BaseKernel {
39
39
await this . serviceContainer . deviceService . sendInterrupt ( ) ;
40
40
}
41
41
42
+ outputResponse ( msg : string ) : void {
43
+ console . log ( "[Kernel] outputResponse - Streaming output:" , msg ) ;
44
+
45
+ msg += '\n' ;
46
+
47
+ this . stream ( ) {
48
+ name : 'stdout' ,
49
+ text : msg ,
50
+ }
51
+ }
52
+
42
53
async executeRequest (
43
54
content : KernelMessage . IExecuteRequestMsg [ 'content' ] ,
44
55
) : Promise < KernelMessage . IExecuteReplyMsg [ 'content' ] > {
@@ -58,28 +69,13 @@ export class EmbeddedKernel extends BaseKernel {
58
69
console . log ( "[Kernel] executeRequest - Processing code" ) ;
59
70
const { code } = content ;
60
71
61
- console . log ( 'Before reconnect check' ) ;
62
72
if ( code . includes ( reconnectString ) ) {
63
73
// Reconnect the device or connect for the first time
64
- console . log ( ' Reconnect command detected, reconnecting device...' ) ;
74
+ this . outputResponse ( " Reconnect command detected, reconnecting device..." ) ;
65
75
await this . serviceContainer . deviceService . disconnect ( ) ;
66
- console . log ( 'Device disconnected' ) ;
67
76
await this . serviceContainer . deviceService . connect ( ) ;
68
- console . log ( 'Device connected' ) ;
69
- this . stream (
70
- {
71
- name : 'stdout' ,
72
- text : "Device Connected!"
73
- }
74
- )
77
+ this . outputResponse ( 'Device Connected!' ) ;
75
78
}
76
- this . stream (
77
- {
78
- name : 'stdout' ,
79
- text : "Device Connect Done!"
80
- }
81
- )
82
- console . log ( 'After reconnect check' ) ;
83
79
84
80
try {
85
81
console . log ( "[Kernel] executeRequest - Checking transport" ) ;
0 commit comments