Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 1 of 1 for serverCanceled (0.06 seconds)

  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")
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 36.1K bytes
    - Click Count (0)
Back to Top