Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1881 - 1890 of 2,137 for breathe (0.04 sec)

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

    	logCh := h.logCh
    	if logCh != nil {
    		// We are not allowed to add when logCh is nil
    		h.wg.Add(1)
    		defer h.wg.Done()
    	}
    	h.logChMu.RUnlock()
    
    	if logCh == nil {
    		return
    	}
    
    	// Create a routine which sends json logs received
    	// from an internal channel.
    	for entry := range logCh {
    		h.logEntry(entry)
    	}
    }
    
    func (h *Target) logEntry(entry any) {
    	atomic.AddInt64(&h.totalMessages, 1)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 10.2K bytes
    - Viewed (0)
  2. src/test/java/jcifs/internal/smb2/Smb2EchoResponseTest.java

            echoResponse = new Smb2EchoResponse(mockConfig);
        }
    
        @Nested
        @DisplayName("Constructor Tests")
        class ConstructorTests {
    
            @Test
            @DisplayName("Should create response with configuration")
            void testConstructor() {
                Smb2EchoResponse response = new Smb2EchoResponse(mockConfig);
                assertNotNull(response);
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 15.1K bytes
    - Viewed (0)
  3. src/test/java/jcifs/smb1/util/HexdumpTest.java

        @DisplayName("Should handle hexdump with offset")
        void testHexdumpWithOffset() {
            ByteArrayOutputStream baos = new ByteArrayOutputStream();
            PrintStream ps = new PrintStream(baos);
    
            // Create test data and dump from offset
            byte[] data = createTestData(64);
            int offset = 16;
            int length = 32;
    
            Hexdump.hexdump(ps, data, offset, length);
            String output = baos.toString();
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  4. impl/maven-core/src/main/java/org/apache/maven/artifact/repository/MavenArtifactRepository.java

        private Proxy proxy;
    
        private List<ArtifactRepository> mirroredRepositories = Collections.emptyList();
    
        private boolean blocked;
    
        public MavenArtifactRepository() {}
    
        /**
         * Create a remote download repository.
         *
         * @param id        the unique identifier of the repository
         * @param url       the URL of the repository
         * @param layout    the layout of the repository
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Jun 06 14:28:57 UTC 2025
    - 12.1K bytes
    - Viewed (0)
  5. docs/es/docs/environment-variables.md

    Las variables de entorno pueden ser útiles para manejar **configuraciones** de aplicaciones, como parte de la **instalación** de Python, etc.
    
    ## Crear y Usar Variables de Entorno { #create-and-use-env-vars }
    
    Puedes **crear** y usar variables de entorno en la **shell (terminal)**, sin necesidad de Python:
    
    //// tab | Linux, macOS, Windows Bash
    
    <div class="termy">
    
    ```console
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Tue Dec 16 16:33:45 UTC 2025
    - 8.5K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/io/CharStreamsTest.java

        CharBuffer empty = CharBuffer.wrap("");
        assertEquals(0, CharStreams.exhaust(empty));
        assertEquals(0, empty.remaining());
      }
    
      public void testNullWriter() throws Exception {
        // create a null writer
        Writer nullWriter = CharStreams.nullWriter();
        // write to the writer
        nullWriter.write('n');
        String test = "Test string for NullWriter";
        nullWriter.write(test);
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Oct 28 16:03:47 UTC 2025
    - 11.3K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java

        input.addListener(output, rejectionPropagatingExecutor(executor, output));
        return output;
      }
    
      static <I extends @Nullable Object, O extends @Nullable Object> ListenableFuture<O> create(
          ListenableFuture<I> input, Function<? super I, ? extends O> function, Executor executor) {
        TransformFuture<I, O> output = new TransformFuture<>(input, function);
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Feb 20 18:03:37 UTC 2025
    - 10.8K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/io/CharStreamsTest.java

        CharBuffer empty = CharBuffer.wrap("");
        assertEquals(0, CharStreams.exhaust(empty));
        assertEquals(0, empty.remaining());
      }
    
      public void testNullWriter() throws Exception {
        // create a null writer
        Writer nullWriter = CharStreams.nullWriter();
        // write to the writer
        nullWriter.write('n');
        String test = "Test string for NullWriter";
        nullWriter.write(test);
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Oct 28 16:03:47 UTC 2025
    - 11.3K bytes
    - Viewed (0)
  9. cmd/os_unix.go

    		i--
    	}
    
    	j := i
    	for j > 0 && !os.IsPathSeparator(dirPath[j-1]) { // Scan backward over element.
    		j--
    	}
    
    	if j > 1 {
    		// Create parent.
    		if err := osMkdirAll(dirPath[:j-1], perm, baseDir); err != nil {
    			return err
    		}
    	}
    
    	// Parent now exists; invoke Mkdir and use its result.
    	if err := Mkdir(dirPath, perm); err != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 9.3K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/collect/ArrayTable.java

       * @throws IllegalArgumentException if {@code rowKeys} or {@code columnKeys} contains duplicates
       *     or if exactly one of {@code rowKeys} or {@code columnKeys} is empty.
       */
      public static <R, C, V> ArrayTable<R, C, V> create(
          Iterable<? extends R> rowKeys, Iterable<? extends C> columnKeys) {
        return new ArrayTable<>(rowKeys, columnKeys);
      }
    
      /*
       * TODO(jlevy): Add factory methods taking an Enum class, instead of an
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Aug 13 19:39:21 UTC 2025
    - 26.2K bytes
    - Viewed (0)
Back to top