Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for newMuxStateless (0.07 sec)

  1. internal/grid/muxserver.go

    	inbound            chan []byte
    	parent             *Connection
    	sendMu             sync.Mutex
    	recvMu             sync.Mutex
    	outBlock           chan struct{}
    	clientPingInterval time.Duration
    }
    
    func newMuxStateless(ctx context.Context, msg message, c *Connection, handler StatelessHandler) *muxServer {
    	var cancel context.CancelFunc
    	ctx = setCaller(ctx, c.remote)
    	if msg.DeadlineMS > 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 9.7K bytes
    - Viewed (0)
Back to top