written - Code Search

okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/GzipRequestBody.kt

) : RequestBody() {
  override fun contentType() = delegate.contentType()

  // We don't know the compressed length in advance!
  override fun contentLength() = -1L

  override fun writeTo(sink: BufferedSink) {
    GzipSink(sink).buffer().use(delegate::writeTo)
  }

  override fun isOneShot() = delegate.isOneShot()

Registered: Fri Sep 05 11:42:10 UTC 2025

- Last Modified: Wed Jun 04 17:43:43 UTC 2025

- 1.1K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

CHANGELOG/CHANGELOG-1.20.md

### Dockershim deprecation

Docker as an underlying runtime is being deprecated. Docker-produced images will continue to work in your cluster with all runtimes, as they always have.
The Kubernetes community [has written a blog post about this in detail](https://blog.k8s.io/2020/12/02/dont-panic-kubernetes-and-docker/) with [a dedicated FAQ page for it](https://blog.k8s.io/2020/12/02/dockershim-faq/).

### External credential provider for client-go

Registered: Fri Sep 05 09:05:11 UTC 2025

- Last Modified: Wed Jan 19 21:05:45 UTC 2022

- 409K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/test/java/jcifs/internal/smb2/tree/Smb2TreeDisconnectResponseTest.java

    }

    @Test
    @DisplayName("Should write empty bytes to wire format")
    void testWriteBytesWireFormat() {
        // Given
        byte[] buffer = new byte[256];
        int offset = 10;

        // When
        int bytesWritten = response.writeBytesWireFormat(buffer, offset);

        // Then
        assertEquals(0, bytesWritten);
    }

    @DisplayName("Should write zero bytes at various offsets")

Registered: Sun Sep 07 00:10:21 UTC 2025

- Last Modified: Thu Aug 14 05:31:44 UTC 2025

- 14.1K bytes

- Viewed (0)

github.com/google/guava

android/guava/src/com/google/common/collect/MapMaker.java

   * be performed atomically on the returned map. Additionally, {@code size} and {@code
   * containsValue} are implemented as bulk read operations, and thus may fail to observe concurrent
   * writes.
   *
   * @return a serializable concurrent map having the requested features
   */
  public <K, V> ConcurrentMap<K, V> makeMap() {
    if (!useCustomMap) {

Registered: Fri Sep 05 12:43:10 UTC 2025

- Last Modified: Thu Aug 07 16:05:33 UTC 2025

- 12.8K bytes

- Viewed (0)

github.com/codelibs/fess

src/test/java/org/codelibs/fess/helper/ThemeHelperTest.java

            zos.putNextEntry(viewEntry);
            zos.write("<html>test</html>".getBytes());
            zos.closeEntry();

            // Add CSS file
            ZipEntry cssEntry = new ZipEntry("css/style.css");
            zos.putNextEntry(cssEntry);
            zos.write("body { color: red; }".getBytes());
            zos.closeEntry();
        }
    }

Registered: Thu Sep 04 12:52:25 UTC 2025

- Last Modified: Sat Jul 19 23:49:30 UTC 2025

- 14.5K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb1/netbios/SocketOutputStream.java

    SocketOutputStream(final OutputStream out) {
        super(out);
    }

    @Override
    public synchronized void write(final byte[] b, int off, final int len) throws IOException {
        if (len > 0xFFFF) {
            throw new IOException("write too large: " + len);
        }
        if (off < 4) {
            throw new IOException("NetBIOS socket output buffer requires 4 bytes available before off");

Registered: Sun Sep 07 00:10:21 UTC 2025

- Last Modified: Thu Aug 14 07:14:38 UTC 2025

- 1.7K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/internal/smb2/rdma/RdmaNegotiateResponse.java

    }

    /**
     * Get maximum read/write size
     *
     * @return maximum read/write size in bytes
     */
    public int getMaxReadWriteSize() {
        return maxReadWriteSize;
    }

    /**
     * Set maximum read/write size
     *
     * @param maxReadWriteSize maximum read/write size in bytes
     */
    public void setMaxReadWriteSize(int maxReadWriteSize) {

Registered: Sun Sep 07 00:10:21 UTC 2025

- Last Modified: Sat Aug 23 05:11:12 UTC 2025

- 4.1K bytes

- Viewed (0)

github.com/golang/go

src/archive/zip/fuzz_test.go

			ww, err := w.CreateHeader(f.header)
			if err != nil {
				t.Fatalf("unable to write previously parsed header: %s", err)
			}
			if _, err := ww.Write(f.content); err != nil {
				t.Fatalf("unable to write previously parsed content: %s", err)
			}
		}

		if err := w.Close(); err != nil {
			t.Fatalf("Unable to write archive: %s", err)
		}

		// TODO: We may want to check if the archive roundtrips.
	})

Registered: Tue Sep 09 11:13:09 UTC 2025

- Last Modified: Thu Jan 13 18:06:33 UTC 2022

- 1.7K bytes

- Viewed (0)

github.com/minio/minio

cmd/batch-handlers.go

						slowCh <- obj
						continue
					}

					batch = append(batch, obj.Item)

					if len(batch) < *r.Source.Snowball.Batch {
						continue
					}
					writeFn(batch)
					batch = batch[:0]
				}
				writeFn(batch)
				xioutil.SafeClose(slowCh)
			}()
		} else {
			slowCh = walkCh
		}

Registered: Sun Sep 07 19:28:11 UTC 2025

- Last Modified: Fri Aug 29 02:39:48 UTC 2025

- 63.5K bytes

- Viewed (0)

github.com/codelibs/fess-suggest

src/main/java/org/codelibs/fess/suggest/index/writer/SuggestWriterResult.java

 * governing permissions and limitations under the License.
 */
package org.codelibs.fess.suggest.index.writer;

import java.util.ArrayList;
import java.util.Collections;
import java.util.List;

/**
 * The SuggestWriterResult class is used to store and manage the results of a suggest writer operation.
 * It keeps track of any failures that occur during the operation.
 */
public class SuggestWriterResult {
    /**

Registered: Fri Sep 19 09:08:11 UTC 2025

- Last Modified: Fri Jul 04 14:00:23 UTC 2025

- 1.9K bytes

- Viewed (0)

Search Options