Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 181 - 190 of 511 for pulling (0.04 seconds)

  1. internal/logger/target/kafka/kafka_scram_client_contrib.go

    // very first conversation step) and attempts to move the authentication
    // conversation forward.  It returns a string to be sent to the server or an
    // error if the server message is invalid.  Calling Step after a conversation
    // completes is also an error.
    func (x *XDGSCRAMClient) Step(challenge string) (response string, err error) {
    	response, err = x.ClientConversation.Step(challenge)
    	return response, err
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 3.3K bytes
    - Click Count (0)
  2. src/main/java/jcifs/smb1/netbios/NbtAddress.java

     * ---------------------------------------------
     * JMORRIS2        <00>  UNIQUE      Registered
     * BILLING-NY      <00>  GROUP       Registered
     * JMORRIS2        <03>  UNIQUE      Registered
     * JMORRIS2        <20>  UNIQUE      Registered
     * BILLING-NY      <1E>  GROUP       Registered
     * JMORRIS         <03>  UNIQUE      Registered
     *
     * MAC Address = 00-B0-34-21-FA-3B
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 31.7K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/collect/AbstractMultimap.java

       *
       * @see Map#hashCode
       */
      @Override
      public int hashCode() {
        return asMap().hashCode();
      }
    
      /**
       * Returns a string representation of the multimap, generated by calling {@code toString} on the
       * map returned by {@link Multimap#asMap}.
       *
       * @return a string representation of the multimap
       */
      @Override
      public String toString() {
        return asMap().toString();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Aug 09 01:14:59 GMT 2025
    - 6.4K bytes
    - Click Count (0)
  4. guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java

       * {@code schedule}, {@code scheduleAtFixedRate}, and {@code scheduleWithFixedDelay}. In the case
       * of tasks submitted by {@code invokeAll} or {@code invokeAny}, tasks will run serially on the
       * calling thread. Tasks are run to completion before a {@code Future} is returned to the caller
       * (unless the executor has been shutdown).
       *
       * <p>The returned executor is backed by the executor returned by {@link
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jul 17 15:26:41 GMT 2025
    - 6.6K bytes
    - Click Count (0)
  5. cmd/object-api-getobjectinfo_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"bytes"
    	"context"
    	"testing"
    )
    
    // Wrapper for calling GetObjectInfo tests for both Erasure multiple disks and single node setup.
    func TestGetObjectInfo(t *testing.T) {
    	ExecObjectLayerTest(t, testGetObjectInfo)
    }
    
    // Testing GetObjectInfo().
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Dec 23 15:46:00 GMT 2022
    - 5.6K bytes
    - Click Count (0)
  6. internal/grid/connection_test.go

    		}
    		gotResp <- struct{}{}
    	}()
    
    	<-gotCall
    	remote.debugMsg(debugKillOutbound)
    	local.debugMsg(debugKillOutbound)
    	errFatal(remoteConn.WaitForConnect(t.Context()))
    
    	<-gotResp
    	// Killing should cancel the context on the request.
    	<-gotCall
    }
    
    func TestShouldConnect(t *testing.T) {
    	var c Connection
    	var cReverse Connection
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 5.9K bytes
    - Click Count (0)
  7. guava/src/com/google/common/collect/Lists.java

       * tiny bit of syntactic sugar for {@code new ArrayList<>(}{@link Arrays#asList asList}{@code
       * (...))}, or for creating an empty list then calling {@link Collections#addAll}. This method is
       * not actually very useful.
       */
      @SafeVarargs
      @SuppressWarnings("NonApiType") // acts as a direct substitute for a constructor call
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 16:38:09 GMT 2026
    - 42.5K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/util/concurrent/AggregateFuture.java

       * initialization; we can't put this in the constructor because, in the case where futures are
       * already complete, we would not initialize the subclass before calling {@link
       * #collectValueFromNonCancelledFuture}. As this is called after the subclass is constructed,
       * we're guaranteed to have properly initialized the subclass.
       */
      final void init() {
        /*
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 16K bytes
    - Click Count (0)
  9. api/maven-api-xml/src/main/java/org/apache/maven/api/xml/XmlNode.java

        /**
         * This default mode for combining children DOMs during merge means that where element names match, the process will
         * try to merge the element data, rather than putting the dominant and recessive elements (which share the same
         * element name) as siblings in the resulting DOM.
         */
        @Deprecated(since = "4.0.0", forRemoval = true)
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Dec 17 15:20:44 GMT 2025
    - 18.3K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/collect/MinMaxPriorityQueue.java

          return index;
        }
    
        // About the term "aunt node": it's better to leave gender out of it, but for this the English
        // language has nothing for us. Except for the whimsical neologism "pibling" (!) which we
        // obviously could not expect to increase anyone's understanding of the code.
    
        /**
         * Swap {@code actualLastElement} with the conceptually correct last element of the heap.
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 13:11:08 GMT 2026
    - 34K bytes
    - Click Count (0)
Back to Top