Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for serverCanceled (0.09 sec)

  1. internal/grid/grid_test.go

    	remoteHost := remote.HostName()
    
    	// 1: Echo
    	serverCanceled := make(chan struct{})
    	register := func(manager *Manager) {
    		errFatal(manager.RegisterStreamingHandler(handlerTest, StreamHandler{
    			Handle: func(ctx context.Context, payload []byte, request <-chan []byte, resp chan<- []byte) *RemoteErr {
    				<-ctx.Done()
    				serverCanceled <- struct{}{}
    				fmt.Println(GetCaller(ctx).Name, "Server Context canceled")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 36.4K bytes
    - Viewed (0)
Back to top