- Sort Score
- Num 10 results
- Language All
Results 1 - 3 of 3 for remotePeer (0.06 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
internal/grid/grid_test.go
errFatal(local.RegisterSingleHandler(handlerTest, func(payload []byte) ([]byte, *RemoteErr) { t.Log("1: server payload: ", len(payload), "bytes.") return append([]byte{}, payload...), nil })) // 2: Return as error errFatal(local.RegisterSingleHandler(handlerTest2, func(payload []byte) ([]byte, *RemoteErr) { t.Log("2: server payload: ", len(payload), "bytes.") err := RemoteErr(payload) return nil, &err })) remote := grid.Managers[1]
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) -
internal/grid/README.md
The server handler function has this signature: `type SingleHandlerFn func(payload []byte) ([]byte, *RemoteErr)`. Sample handler: ```go handler := func(payload []byte) ([]byte, *grid.RemoteErr) { // Do something with payload return []byte("response"), nil } err := manager.RegisterSingleHandler(grid.HandlerDiskInfo, handler) ```
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Oct 10 18:57:03 GMT 2025 - 9.4K bytes - Click Count (0) -
internal/grid/connection.go
} PutByteBuffer(m.Payload) return } if m.Flags&FlagPayloadIsErr != 0 { v.response(m.Seq, Response{ Msg: nil, Err: RemoteErr(m.Payload), }) if v.cancelFn != nil { v.cancelFn(RemoteErr(m.Payload)) } PutByteBuffer(m.Payload) v.close() c.outgoing.Delete(m.MuxID) return } // Return payload. if m.Payload != nil {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 46.9K bytes - Click Count (0)