- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for StreamHandler (0.27 sec)
-
internal/grid/grid_test.go
} } // We fake a local and remote server. remoteHost := remote.HostName() // 1: Echo register := func(manager *Manager) { errFatal(manager.RegisterStreamingHandler(handlerTest, StreamHandler{ Handle: func(ctx context.Context, payload []byte, request <-chan []byte, resp chan<- []byte) *RemoteErr { for in := range request { b := append([]byte{}, payload...) b = append(b, in...)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:03:35 GMT 2024 - 30.1K bytes - Viewed (0)