Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for DeadlineMS (0.17 sec)

  1. internal/grid/muxserver.go

    }
    
    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 {
    		ctx, cancel = context.WithTimeout(ctx, time.Duration(msg.DeadlineMS)*time.Millisecond)
    	} else {
    		ctx, cancel = context.WithCancel(ctx)
    	}
    	m := muxServer{
    		ID:        msg.MuxID,
    		RecvSeq:   msg.Seq + 1,
    		SendSeq:   msg.Seq,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.1K bytes
    - Viewed (0)
Back to top