How to use ResumeIntercepting method of internal Package

...39	StartInterceptingOutput()40	StartInterceptingOutputAndForwardTo(io.Writer)41	StopInterceptingAndReturnOutput() string42	PauseIntercepting()43	ResumeIntercepting()44	Shutdown()45}46func NewOutputInterceptor() OutputInterceptor {47	return NewOSGlobalReassigningOutputInterceptor()48}49type NoopOutputInterceptor struct{}50func (interceptor NoopOutputInterceptor) StartInterceptingOutput()                      {}51func (interceptor NoopOutputInterceptor) StartInterceptingOutputAndForwardTo(io.Writer) {}52func (interceptor NoopOutputInterceptor) StopInterceptingAndReturnOutput() string       { return "" }53func (interceptor NoopOutputInterceptor) PauseIntercepting()                            {}54func (interceptor NoopOutputInterceptor) ResumeIntercepting()                           {}55func (interceptor NoopOutputInterceptor) Shutdown()                                     {}56type pipePair struct {57	reader *os.File58	writer *os.File59}60func startPipeFactory(pipeChannel chan pipePair, shutdown chan interface{}) {61	for {62		//make the next pipe...63		pair := pipePair{}64		pair.reader, pair.writer, _ = os.Pipe()65		select {66		//...and provide it to the next consumer (they are responsible for closing the files)67		case pipeChannel <- pair:68			continue69		//...or close the files if we were told to shutdown70		case <-shutdown:71			pair.reader.Close()72			pair.writer.Close()73			return74		}75	}76}77type interceptorImplementation interface {78	CreateStdoutStderrClones() (*os.File, *os.File)79	ConnectPipeToStdoutStderr(*os.File)80	RestoreStdoutStderrFromClones(*os.File, *os.File)81	ShutdownClones(*os.File, *os.File)82}83type genericOutputInterceptor struct {84	intercepting bool85	stdoutClone *os.File86	stderrClone *os.File87	pipe        pipePair88	shutdown           chan interface{}89	emergencyBailout   chan interface{}90	pipeChannel        chan pipePair91	interceptedContent chan string92	forwardTo         io.Writer93	accumulatedOutput string94	implementation interceptorImplementation95}96func (interceptor *genericOutputInterceptor) StartInterceptingOutput() {97	interceptor.StartInterceptingOutputAndForwardTo(io.Discard)98}99func (interceptor *genericOutputInterceptor) StartInterceptingOutputAndForwardTo(w io.Writer) {100	if interceptor.intercepting {101		return102	}103	interceptor.accumulatedOutput = ""104	interceptor.forwardTo = w105	interceptor.ResumeIntercepting()106}107func (interceptor *genericOutputInterceptor) StopInterceptingAndReturnOutput() string {108	if interceptor.intercepting {109		interceptor.PauseIntercepting()110	}111	return interceptor.accumulatedOutput112}113func (interceptor *genericOutputInterceptor) ResumeIntercepting() {114	if interceptor.intercepting {115		return116	}117	interceptor.intercepting = true118	if interceptor.stdoutClone == nil {119		interceptor.stdoutClone, interceptor.stderrClone = interceptor.implementation.CreateStdoutStderrClones()120		interceptor.shutdown = make(chan interface{})121		go startPipeFactory(interceptor.pipeChannel, interceptor.shutdown)122	}123	// Now we make a pipe, we'll use this to redirect the input to the 1 and 2 file descriptors (this is how everything else in the world is tring to log to stdout and stderr)124	// we get the pipe from our pipe factory.  it runs in the background so we can request the next pipe while the spec being intercepted is running125	interceptor.pipe = <-interceptor.pipeChannel126	interceptor.emergencyBailout = make(chan interface{})127	//Spin up a goroutine to copy data from the pipe into a buffer, this is how we capture any output the user is emitting...

...79			cmd := exec.Command("sleep", "60")80			//by threading stdout and stderr through, the sleep process will hold them open and prevent the interceptor from stopping:81			cmd.Stdout, cmd.Stderr = os.Stdout, os.Stderr82			Ω(cmd.Start()).Should(Succeed())83			interceptor.ResumeIntercepting()84			fmt.Println("hi stdout")85			fmt.Fprintln(os.Stderr, "hi stderr")86			output := interceptor.StopInterceptingAndReturnOutput()87			Ω(output).Should(Equal("hi stdout\nhi stderr\n"))88			Ω(output).ShouldNot(ContainSubstring(internal.BAILOUT_MESSAGE))89			cmd.Process.Kill()90		})91		It("can start/stop/pause/resume correctly", func() {92			interceptor.StartInterceptingOutput()93			fmt.Fprint(os.Stdout, "O-A")94			fmt.Fprint(os.Stderr, "E-A")95			interceptor.PauseIntercepting()96			fmt.Fprint(os.Stdout, "O-B")97			fmt.Fprint(os.Stderr, "E-B")98			interceptor.ResumeIntercepting()99			fmt.Fprint(os.Stdout, "O-C")100			fmt.Fprint(os.Stderr, "E-C")101			interceptor.ResumeIntercepting() //noop102			fmt.Fprint(os.Stdout, "O-D")103			fmt.Fprint(os.Stderr, "E-D")104			interceptor.PauseIntercepting()105			fmt.Fprint(os.Stdout, "O-E")106			fmt.Fprint(os.Stderr, "E-E")107			interceptor.PauseIntercepting() //noop108			fmt.Fprint(os.Stdout, "O-F")109			fmt.Fprint(os.Stderr, "E-F")110			interceptor.ResumeIntercepting()111			fmt.Fprint(os.Stdout, "O-G")112			fmt.Fprint(os.Stderr, "E-G")113			interceptor.StartInterceptingOutput() //noop114			fmt.Fprint(os.Stdout, "O-H")115			fmt.Fprint(os.Stderr, "E-H")116			interceptor.PauseIntercepting()117			output := interceptor.StopInterceptingAndReturnOutput()118			Ω(output).Should(Equal("O-AE-AO-CE-CO-DE-DO-GE-GO-HE-H"))119		})120	}121	Context("the OutputInterceptor for this OS", func() {122		BeforeEach(func() {123			interceptor = internal.NewOutputInterceptor()124			DeferCleanup(interceptor.Shutdown)...

1import (2func main() {3	vm := otto.New()4	vm.Interrupt = make(chan func(), 1)5	go func() {6		vm.Interrupt <- func() {7			fmt.Println("Interrupted!")8		}9	}()10	vm.Run(`while(true) { ; }`)11}12import (13func main() {14	vm := otto.New()15	vm.Interrupt = make(chan func(), 1)16	go func() {17		vm.Interrupt <- func() {18			fmt.Println("Interrupted!")19		}20	}()21	vm.Run(`while(true) { ; }`)22}23import (24func main() {25	vm := otto.New()26	vm.Interrupt = make(chan func(), 1)27	go func() {28		vm.Interrupt <- func() {29			fmt.Println("Interrupted!")30		}31	}()32	vm.Run(`while(true) { ; }`)33}34import (35func main() {36	vm := otto.New()37	vm.Interrupt = make(chan func(), 1)38	go func() {39		vm.Interrupt <- func() {40			fmt.Println("Interrupted!")41		}42	}()43	vm.Run(`while(true) { ; }`)44}45import (46func main() {47	vm := otto.New()48	vm.Interrupt = make(chan func(), 1)49	go func() {50		vm.Interrupt <- func() {51			fmt.Println("Interrupted!")52		}53	}()54	vm.Run(`while(true) { ; }`)55}

1import (2func main() {3	vm := otto.New()4	vm.Run(`5		var a = 1;6		var b = 2;7		var c = 3;8	vm.Interrupt = make(chan func(), 1)9	vm.Interrupt <- func() {10		fmt.Println("interrupted")11	}12	vm.Run(`13		var d = 4;14		var e = 5;15		var f = 6;16}17import (18func main() {19	vm := otto.New()20	vm.Run(`21		var a = 1;22		var b = 2;23		var c = 3;24	vm.Interrupt = make(chan func(), 1)25	vm.Interrupt <- func() {26		fmt.Println("interrupted")27	}28	vm.ResumeIntercepting()29	vm.Run(`30		var d = 4;31		var e = 5;32		var f = 6;33}34import (35func main() {36	vm := otto.New()37	vm.Run(`38		var a = 1;39		var b = 2;40		var c = 3;41	vm.Interrupt = make(chan func(), 1)42	vm.Interrupt <- func() {43		fmt.Println("interrupted")44	}45	vm.ResumeIntercepting()46	vm.Interrupt <- func() {47		fmt.Println("interrupted")48	}49	vm.Run(`50		var d = 4;51		var e = 5;52		var f = 6;53}54import (55func main() {56	vm := otto.New()57	vm.Run(`58		var a = 1;59		var b = 2;

1import "internal/1.go"2func main() {3    v.ResumeIntercepting()4}5type Internal struct {}6func (i Internal) ResumeIntercepting() {}

1import (2func main() {3	fmt.Println("Hello World")4	internal.ResumeIntercepting()5}6import (7func main() {8	fmt.Println("Hello World")9	internal.ResumeIntercepting()10}11import (12func main() {13	fmt.Println("Hello World")14	internal.ResumeIntercepting()15}16import (17func main() {18	fmt.Println("Hello World")19	internal.ResumeIntercepting()20}21import (22func main() {23	fmt.Println("Hello World")24	internal.ResumeIntercepting()25}26import (27func main() {28	fmt.Println("Hello World")29	internal.ResumeIntercepting()30}31import (32func main() {33	fmt.Println("Hello World")34	internal.ResumeIntercepting()35}36import (37func main() {38	fmt.Println("Hello World

1import (2func main() {3	s := &fasthttp.Server{4	}5	log.Fatal(s.ListenAndServe(":8080"))6}7func fasthttpHandler(ctx *fasthttp.RequestCtx) {8	req := &http.Request{}9	req = resumeIntercepting(ctx)10	fmt.Println(path)11}12func resumeIntercepting(ctx *fasthttp.RequestCtx) *http.Request {13	internal := reflect.ValueOf(ctx).Elem()14	field := internal.FieldByName("req")15	req := field.Addr().Interface().(*http.Request)16}17import (18func main() {19	s := &fasthttp.Server{20	}21	log.Fatal(s.ListenAndServe(":8080"))22}23func fasthttpHandler(ctx *fasthttp.RequestCtx) {24	req := &http.Request{}25	req = resumeIntercepting(ctx)26	fmt.Println(path)27}28func resumeIntercepting(ctx *fasthttp.RequestCtx) *http.Request {29	field := internal.Req()30}