- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for WithCancelCause (0.18 sec)
-
internal/grid/muxclient.go
} // Response is a response from the server. type Response struct { Msg []byte Err error } func newMuxClient(ctx context.Context, muxID uint64, parent *Connection) *muxClient { ctx, cancelFn := context.WithCancelCause(ctx) return &muxClient{ MuxID: muxID, ctx: ctx, cancelFn: cancelFn, parent: parent, LastPong: time.Now().Unix(), BaseFlags: parent.baseFlags, } }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
internal/grid/connection.go
// handleMessages will handle incoming messages on conn. // caller *must* hold reconnectMu. func (c *Connection) handleMessages(ctx context.Context, conn net.Conn) { c.updateState(StateConnected) ctx, cancel := context.WithCancelCause(ctx) defer cancel(ErrDisconnected) // This will ensure that is something asks to disconnect and we are blocked on reads/writes // the connection will be closed and readers/writers will unblock.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
api/go1.20.txt
pkg bytes, func CutPrefix([]uint8, []uint8) ([]uint8, bool) #42537 pkg bytes, func CutSuffix([]uint8, []uint8) ([]uint8, bool) #42537 pkg context, func Cause(Context) error #51365 pkg context, func WithCancelCause(Context) (Context, CancelCauseFunc) #51365 pkg context, type CancelCauseFunc func(error) #51365 pkg crypto/ecdh, func P256() Curve #52221 pkg crypto/ecdh, func P384() Curve #52221 pkg crypto/ecdh, func P521() Curve #52221
Plain Text - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Feb 17 21:23:32 GMT 2023 - 602.6K bytes - Viewed (0)