Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 2 of 2 for WaitForConnect (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. internal/grid/connection.go

    }
    
    // WaitForConnect will block until a connection has been established or
    // the context is canceled, in which case the context error is returned.
    func (c *Connection) WaitForConnect(ctx context.Context) error {
    	if debugPrint {
    		fmt.Println(c.Local, "->", c.Remote, "WaitForConnect")
    		defer fmt.Println(c.Local, "->", c.Remote, "WaitForConnect done")
    	}
    	c.connChange.L.Lock()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 46.9K bytes
    - Click Count (0)
  2. internal/grid/connection_test.go

    	errFatal(local.RegisterSingleHandler(handlerTest, h1))
    	errFatal(local.RegisterStreamingHandler(handlerTest2, h2))
    
    	// local to remote
    	remoteConn := local.Connection(remoteHost)
    	errFatal(remoteConn.WaitForConnect(t.Context()))
    	const testPayload = "Hello Grid World!"
    
    	gotResp := make(chan struct{})
    	go func() {
    		start := time.Now()
    		t.Log("Roundtrip: sending request")
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 5.9K bytes
    - Click Count (0)
Back to Top