- Sort Score
- Num 10 results
- Language All
Results 11 - 20 of 1,860 for receiver (0.08 seconds)
-
internal/logger/target/kafka/kafka_scram_client_contrib.go
// each authentication attempt. type XDGSCRAMClient struct { *scram.Client *scram.ClientConversation scram.HashGeneratorFcn } // Begin constructs a SCRAM client component based on a given hash.Hash // factory receiver. This constructor will normalize the username, password // and authzID via the SASLprep algorithm, as recommended by RFC-5802. If // SASLprep fails, the method returns an error.Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 3.3K bytes - Click Count (0) -
internal/event/target/kafka_scram_client_contrib.go
// each authentication attempt. type XDGSCRAMClient struct { *scram.Client *scram.ClientConversation scram.HashGeneratorFcn } // Begin constructs a SCRAM client component based on a given hash.Hash // factory receiver. This constructor will normalize the username, password // and authzID via the SASLprep algorithm, as recommended by RFC-5802. If // SASLprep fails, the method returns an error.Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 3.2K bytes - Click Count (0) -
internal/grid/msg.go
// m.Payload is length 0, but not nil. func (m *message) setZeroPayloadFlag() { m.Flags &^= FlagPayloadIsZero if len(m.Payload) == 0 && m.Payload != nil { m.Flags |= FlagPayloadIsZero } } type receiver interface { msgp.Unmarshaler Op() Op } type sender interface { msgp.MarshalSizer Op() Op } type connectReq struct { ID [16]byte Host string Time time.Time
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Thu Jul 25 21:07:21 GMT 2024 - 7.6K bytes - Click Count (0) -
src/cmd/api/main_test.go
recv := sig.Recv().Type() // report exported methods with unexported receiver base type if true { base := recv if p, _ := recv.(*types.Pointer); p != nil { base = p.Elem() } if obj := base.(*types.Named).Obj(); !obj.Exported() { log.Fatalf("exported method with unexported receiver base type: %s", m) } } tps := "" if rtp := sig.RecvTypeParams(); rtp != nil {
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Thu Feb 20 03:25:33 GMT 2025 - 31.4K bytes - Click Count (0) -
android/guava/src/com/google/common/base/Ascii.java
* identification, or may be used to obtain station status, or both. * * @since 8.0 */ public static final byte ENQ = 5; /** * Acknowledge: A communication control character transmitted by a receiver as an affirmative * response to a sender. * * @since 8.0 */ public static final byte ACK = 6; /**
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Mar 17 20:26:29 GMT 2025 - 21.7K bytes - Click Count (0) -
guava/src/com/google/common/base/Throwables.java
} }; } @J2ktIncompatible @GwtIncompatible // java.lang.reflect private static Object invokeAccessibleNonThrowingMethod( Method method, Object receiver, Object... params) { try { return method.invoke(receiver, params); } catch (IllegalAccessException e) { throw new RuntimeException(e); } catch (InvocationTargetException e) { throw propagate(e.getCause()); }Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 20.6K bytes - Click Count (0) -
build-logic/binary-compatibility/src/main/kotlin/gradlebuild/binarycompatibility/sources/KotlinSourceQueries.kt
} val isVarargs = Modifier.isVarArgs(method.modifiers) // Parameter type check method.parameterTypes .asSequence() // Drop the receiver if present .drop(if (extensionCandidate) 1 else 0) .withIndex() .all { val ktParamType = ktFunction.valueParameters[it.index].typeReference!!Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Tue Jul 08 07:02:19 GMT 2025 - 13.2K bytes - Click Count (0) -
cmd/storage-rest-server.go
// The returned function should always be called to release resources. // An optional error can be sent which will be picked as text only error, // without its original type by the receiver. // waitForHTTPResponse should be used to the receiving side. func keepHTTPReqResponseAlive(w http.ResponseWriter, r *http.Request) (resp func(error), body io.ReadCloser) { bodyDoneCh := make(chan struct{})
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue May 27 15:19:03 GMT 2025 - 45.7K bytes - Click Count (0) -
misc/cgo/gmp/gmp.go
} // Abs sets z to the absolute value of x and returns z. func (z *Int) Abs(x *Int) *Int { x.doinit() z.doinit() C.mpz_abs(&z.i[0], &x.i[0]) return z } /* * functions without a clear receiver */ // CmpInt compares x and y. The result is // // -1 if x < y // 0 if x == y // +1 if x > y func CmpInt(x, y *Int) int { x.doinit() y.doinit()
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Mon Apr 11 16:34:30 GMT 2022 - 9.5K bytes - Click Count (0) -
src/builtin/builtin.go
// bidirectional or send-only. It should be executed only by the sender, // never the receiver, and has the effect of shutting down the channel after // the last sent value is received. After the last value has been received // from a closed channel c, any receive from c will succeed without // blocking, returning the zero value for the channel element. The form // // x, ok := <-c //
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Mon Dec 30 23:59:23 GMT 2024 - 12.8K bytes - Click Count (0)