@@ -3,7 +3,14 @@ import * as sinon from 'sinon';
33import * as fs from 'fs' ;
44import * as path from 'path' ;
55import { CancellationToken , CancellationTokenSource , TestController , TestItem , Uri , Range , Position } from 'vscode' ;
6- import { Emitter , Event , MessageReader , PartialMessageInfo , Disposable as RpcDisposable , DataCallback } from 'vscode-jsonrpc' ;
6+ import {
7+ Emitter ,
8+ Event ,
9+ MessageReader ,
10+ PartialMessageInfo ,
11+ Disposable as RpcDisposable ,
12+ DataCallback ,
13+ } from 'vscode-jsonrpc' ;
714import { Message } from 'vscode-jsonrpc' ;
815import {
916 writeTestIdsFile ,
@@ -786,7 +793,11 @@ suite('startRunResultNamedPipe drain-on-cancel tests', () => {
786793
787794 public listen ( callback : DataCallback ) : RpcDisposable {
788795 this . _callback = callback ;
789- return { dispose : ( ) => { this . _callback = undefined ; } } ;
796+ return {
797+ dispose : ( ) => {
798+ this . _callback = undefined ;
799+ } ,
800+ } ;
790801 }
791802
792803 public dispose ( ) : void {
@@ -830,11 +841,7 @@ suite('startRunResultNamedPipe drain-on-cancel tests', () => {
830841 const deferredTillServerClose : Deferred < void > = createDeferred < void > ( ) ;
831842 const cancelSource = new CancellationTokenSource ( ) ;
832843
833- await startRunResultNamedPipe (
834- ( payload ) => received . push ( payload ) ,
835- deferredTillServerClose ,
836- cancelSource . token ,
837- ) ;
844+ await startRunResultNamedPipe ( ( payload ) => received . push ( payload ) , deferredTillServerClose , cancelSource . token ) ;
838845
839846 assert . ok ( createReaderPipeStub . calledOnce , 'createReaderPipe should be called once' ) ;
840847 assert . ok ( reader . hasListener ( ) , 'reader should have a listener registered before cancel' ) ;
@@ -868,11 +875,7 @@ suite('startRunResultNamedPipe drain-on-cancel tests', () => {
868875 const deferredTillServerClose : Deferred < void > = createDeferred < void > ( ) ;
869876 const cancelSource = new CancellationTokenSource ( ) ;
870877
871- await startRunResultNamedPipe (
872- ( payload ) => received . push ( payload ) ,
873- deferredTillServerClose ,
874- cancelSource . token ,
875- ) ;
878+ await startRunResultNamedPipe ( ( payload ) => received . push ( payload ) , deferredTillServerClose , cancelSource . token ) ;
876879
877880 // Simulate the debug-path race: cancel fires while results are still buffered.
878881 cancelSource . cancel ( ) ;
0 commit comments