In OkHttp we expose a blocking API over a framed protocol. This document explains the code and policy that makes that work.

### Threads

#### Application's calling thread

    }

    /**
     * Verify that writeParameterWordsWireFormat writes the file id and the
     * unsigned time correctly.  The last write time is zero which should be
     * encoded as four 0xFF bytes by {@code writeUTime}.
     */
    @ParameterizedTest(name = "fid={0}, lastWriteTime={1}")
    @MethodSource("validParams")
    @DisplayName("happy: writeParameterWordsWireFormat writes correct bytes")

    }

    // ---------------- Static write tests -----------------
    @Test
    @DisplayName("writeULong writes little endian bytes")
    void testWriteULong() {
        byte[] dest = new byte[4];
        NtlmMessage.writeULong(dest, 0, 0x01020304);
        assertArrayEquals(new byte[] { 4, 3, 2, 1 }, dest, "Writer must be little‑endian");
    }

    @Test

        }
    }

    /**
     * Writes the specified byte to this file output stream.
     *
     * @throws IOException
     *             if a network error occurs
     */

    @Override
    public void write(final int b) throws IOException {
        this.tmp[0] = (byte) b;
        write(this.tmp, 0, 1);
    }

    /**
     * Writes b.length bytes from the specified byte array to this

    }

    /**
     * Writes setup data in wire format
     * @param dst destination buffer
     * @param dstIndex starting index in destination buffer
     * @return number of bytes written
     */
    protected abstract int writeSetupWireFormat(byte[] dst, int dstIndex);

    /**
     * Writes parameters in wire format
     * @param dst destination buffer

    }

    @Test
    @DisplayName("writeSetupWireFormat writes the subCommand and a trailing 0")
    void testWriteSetupWireFormat() {
        Trans2QueryFSInformation cmd = new Trans2QueryFSInformation(5);
        byte[] buf = newBuffer(10);
        int written = cmd.writeSetupWireFormat(buf, 0);
        assertEquals(2, written, "setup packet should write 2 bytes");

        return FormatType.OTHER;
    }

    /**
     * Writes text content to the HTTP response with specified content type and encoding.
     * @param text The text content to write.
     * @param contentType The content type for the response.
     * @param encoding The character encoding for the response.
     */
    protected void write(final String text, final String contentType, final String encoding) {

        assertEquals(expectedAttributes, searchAttributesField.get(smbComRename));
    }

    /**
     * Test writeParameterWordsWireFormat method
     */
    @Test
    @DisplayName("Test writeParameterWordsWireFormat writes search attributes correctly")
    public void testWriteParameterWordsWireFormat() {
        // Given
        byte[] dst = new byte[10];
        smbComRename = new SmbComRename(config, "old.txt", "new.txt");

			}

			if totalGet < throughputHighestGet {
				// Following check is for situations
				// when Writes() scale higher than Reads()
				// - practically speaking this never happens
				// and should never happen - however it has
				// been seen recently due to hardware issues
				// causes Reads() to go slower than Writes().
				//
				// Send such results anyways as this shall
				// expose a problem underneath.

	"path"
	"slices"
	"strings"
	"time"
)

// Writer provides sequential writing of a tar archive.
// [Writer.WriteHeader] begins a new file with the provided [Header],
// and then Writer can be treated as an io.Writer to supply that file's data.
type Writer struct {
	w    io.Writer
	pad  int64      // Amount of padding to write after current file entry
	curr fileWriter // Writer for current file entry