//
// You should have received a copy of the GNU Affero General Public License
// along with this program.  If not, see <http://www.gnu.org/licenses/>.

package dsync

import (
	"bytes"
	"context"
	"errors"
	"net/http"
	"net/url"
	"time"

	xhttp "github.com/minio/minio/internal/http"
	"github.com/minio/minio/internal/rest"
)

// Copyright 2024 The Go Authors. All rights reserved.
// Use of this source code is governed by a BSD-style
// license that can be found in the LICENSE file.

package bytes

import (
	"iter"
	"unicode"
	"unicode/utf8"
)

// Lines returns an iterator over the newline-terminated lines in the byte slice s.
// The lines yielded by the iterator include their terminating newlines.
// If s is empty, the iterator yields no lines at all.

 * bytes in length.
 *
 * The cache stores its data in a directory on the filesystem. This directory must be exclusive to
 * the cache; the cache may delete or overwrite files from its directory. It is an error for
 * multiple processes to use the same cache directory at the same time.
 *
 * This cache limits the number of bytes that it will store on the filesystem. When the number of

        // Any PACDecodingException is acceptable for this test
        assertNotNull(e.getMessage());
    }

    @Test
    void testTooSmallPac() {
        // Test that PAC smaller than 8 bytes is rejected
        byte[] smallData = new byte[4];

        PACDecodingException e = assertThrows(PACDecodingException.class, () -> new Pac(smallData, keys));
        // Any PACDecodingException is acceptable for this test

### Потоковая передача байтов { #stream-bytes }

Один из основных сценариев — стримить `bytes` вместо строк, и, конечно, это можно сделать.

{* ../../docs_src/stream_data/tutorial001_py310.py ln[44:47] hl[47] *}

## Пользовательский `PNGStreamingResponse` { #a-custom-pngstreamingresponse }

		t.Log("1: server payload: ", len(payload), "bytes.")
		return append([]byte{}, payload...), nil
	}))
	// 2: Return as error
	errFatal(local.RegisterSingleHandler(handlerTest2, func(payload []byte) ([]byte, *RemoteErr) {
		t.Log("2: server payload: ", len(payload), "bytes.")
		err := RemoteErr(payload)
		return nil, &err
	}))

   *       the same.
   *   <li>The special characters ".", "-", "*", and "_" remain the same.
   *   <li>The space character " " is converted into a plus sign "+".
   *   <li>All other characters are converted into one or more bytes using UTF-8 encoding and each
   *       byte is then represented by the 3-character string "%XY", where "XY" is the two-digit,
   *       uppercase, hexadecimal representation of the byte value.
   * </ul>
   *

from fastapi import FastAPI, File
from fastapi.testclient import TestClient

app = FastAPI()


@app.post("/files")
async def upload_files(files: list[bytes] | None = File(None)):
    if files is None:
        return {"files_count": 0}
    return {"files_count": len(files), "sizes": [len(f) for f in files]}


def test_optional_bytes_list():
    client = TestClient(app)
    response = client.post(
        "/files",

        // The method should write bytes
        assertEquals(0, result, "writeBytesWireFormat should return 0 for response");
    }

    @Test
    void testReadBytesWireFormat() {
        byte[] buffer = new byte[1024];
        int result = response.readBytesWireFormat(buffer, 0);

        // The method should read bytes

        byte[] dst = new byte[1024];
        int result = setupAndX.writeParameterWordsWireFormat(dst, 0);

        // Verify that data was written (should write 22 bytes based on implementation)
        assertEquals(22, result, "writeParameterWordsWireFormat should write 22 bytes");
    }

    @Test
    void testWriteBytesWireFormat() {
        byte[] dst = new byte[1024];
        int result = setupAndX.writeBytesWireFormat(dst, 0);