Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 20 of 1,860 for receiver (0.04 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top