@@ -3,13 +3,13 @@ import net = require('net');
3
3
import { spawn , ChildProcess } from 'child_process' ;
4
4
import { dirname } from 'path' ;
5
5
6
- interface RSessionRequest {
6
+ interface RKernelRequest {
7
7
id : number ;
8
8
type : 'eval' | 'cancel' ;
9
9
expr ?: any ;
10
10
}
11
11
12
- interface RSessionResponse {
12
+ interface RKernelResponse {
13
13
id : number ;
14
14
type : 'text' | 'plot' | 'viewer' | 'browser' | 'error' ;
15
15
result : string ;
@@ -29,7 +29,7 @@ class RKernel {
29
29
this . doc = doc ;
30
30
}
31
31
32
- private request ( request : RSessionRequest ) {
32
+ private request ( request : RKernelRequest ) {
33
33
if ( this . socket ) {
34
34
const json = JSON . stringify ( request ) ;
35
35
this . socket . write ( `Content-Length: ${ json . length } \n${ json } ` ) ;
@@ -93,11 +93,11 @@ class RKernel {
93
93
await this . start ( ) ;
94
94
}
95
95
96
- public async eval ( cell : vscode . NotebookCell ) : Promise < RSessionResponse > {
96
+ public async eval ( cell : vscode . NotebookCell ) : Promise < RKernelResponse > {
97
97
if ( this . socket ) {
98
98
return new Promise ( ( resolve , reject ) => {
99
99
const handler = async ( data : Buffer ) => {
100
- const response : RSessionResponse = JSON . parse ( data . toString ( ) ) ;
100
+ const response : RKernelResponse = JSON . parse ( data . toString ( ) ) ;
101
101
resolve ( response ) ;
102
102
this . socket . removeListener ( 'data' , handler ) ;
103
103
} ;
@@ -140,7 +140,7 @@ class RNotebook implements vscode.Disposable {
140
140
this . kernel . restart ( ) ;
141
141
}
142
142
143
- public async eval ( cell : vscode . NotebookCell ) : Promise < RSessionResponse > {
143
+ public async eval ( cell : vscode . NotebookCell ) : Promise < RKernelResponse > {
144
144
await this . kernel . start ( ) ;
145
145
return this . kernel . eval ( cell ) ;
146
146
}
0 commit comments