Note over Client: Keeps consuming...
```

データを送り続ける無限ストリームにすることもできます。

## JSON Lines { #json-lines }

このような場合、1 行に 1 つの JSON オブジェクトを送る「**JSON Lines**」形式を使うのが一般的です。

レスポンスの content type は `application/jsonl`（`application/json` の代わり）となり、ボディは次のようになります:

```json
{"name": "Plumbus", "description": "A multi-purpose household device."}
{"name": "Portal Gun", "description": "A portal opening device."}

	Index      []byte            `json:"index,omitempty" msg:"i,omitempty"`
	Checksums  map[string]string `json:"crc,omitempty" msg:"crc,omitempty"`   // Content Checksums
	Error      string            `json:"error,omitempty" msg:"err,omitempty"` // only set while reading part meta from drive.
}

// ChecksumInfo - carries checksums of individual scattered parts per disk.

if [ "${rep_obj2_size}" != "${src_obj2_size}" ]; then
	echo "BUG: Size: '${rep_obj2_size}' of replicated object: 'minio2/test-bucket/defpartsize' doesn't match with source value: '${src_obj2_size}'"
	exit_1
fi

# Check content of replicated SSEC objects
./mc cat minio2/test-bucket/encrypted --enc-c "minio2/test-bucket/encrypted=${TEST_MINIO_ENC_KEY}" --insecure

     *
     * @param url the SMB URL of the file to access
     * @param mode the access mode ("r" for read-only, "rw" for read-write)
     * @param sharing the sharing flags for file access
     * @param tc the CIFS context to use for the connection
     * @throws SmbException if an SMB error occurs
     * @throws MalformedURLException if the URL is malformed
     */
    @SuppressWarnings("resource")

            Smb2WriteResponse response = request.createResponse(mockContext, request);
            assertNotNull(response);
            // Response should be created with the same config from context
            verify(mockContext, times(1)).getConfig();
        }
    }

    @Nested
    @DisplayName("Integration Tests")
    class IntegrationTests {

        @Test

 * </ul>
 *
 * <p>This tool is particularly useful for identifying memory optimization opportunities
 * in large Maven multi-module projects where POM files may contain significant
 * duplicate content.</p>
 */
public class PomMemoryAnalyzer {
    private final Map<String, Map<String, StringStats>> pathStats = new HashMap<>();
    private final Map<String, Integer> globalStringFrequency = new HashMap<>();

    * `Path()`
    * `Query()`
    * `Header()`
    * `Cookie()`
* [`Request Body Object`, у полі `content`, у `Media Type Object` (у специфікації)](https://github.com/OAI/OpenAPI-Specification/blob/main/versions/3.1.0.md#media-type-object), який використовувався утилітами FastAPI:
    * `Body()`
    * `File()`
    * `Form()`

    old_content = content_path.read_text(encoding="utf-8")

    new_content = yaml.dump(new_content, sort_keys=False, width=200, allow_unicode=True)
    if old_content == new_content:
        logging.info(f"The content hasn't changed for {content_path}")
        return False
    content_path.write_text(new_content, encoding="utf-8")
    logging.info(f"Updated {content_path}")
    return True


def main() -> None:

    throwIfUnchecked(throwable);
    throw new RuntimeException(throwable);
  }

  /**
   * Returns the innermost cause of {@code throwable}. The first throwable in a chain provides
   * context from when the error or exception was initially detected. Example usage:
   *
   * <pre>
   * assertEquals("Unable to assign a customer id", Throwables.getRootCause(e).getMessage());
   * </pre>
   *

            Smb2LockResponse response = request.createResponse(mockContext, request);
            assertNotNull(response);
            // Response should be created with the same config from context
            verify(mockContext, times(1)).getConfig();
        }

        @Test
        @DisplayName("Should create response for request with multiple locks")
        void testCreateResponseWithMultipleLocks() {