Skip to content
Merged
Show file tree
Hide file tree
Changes from 2 commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 3 additions & 0 deletions examples/streamed-list-objects/README.md
Original file line number Diff line number Diff line change
@@ -1,5 +1,8 @@
# Streamed List Objects Example

> **NOTE:** This example is temporarily disabled as the `streamedListObjects` API is not yet available for public use. It will be enabled in a future release.

<!--
Demonstrates using `StreamedListObjects` to retrieve objects via the streaming API in the Java SDK.

## What is StreamedListObjects?
Expand Down
Original file line number Diff line number Diff line change
@@ -1,3 +1,7 @@
// NOTE: This example is temporarily commented out as the streamedListObjects API is not yet available for public use.
// It will be enabled in a future release.

/*
package dev.openfga.sdk.example;

import com.fasterxml.jackson.databind.ObjectMapper;
Expand Down Expand Up @@ -192,3 +196,4 @@ private WriteAuthorizationModelRequest createAuthorizationModel() {
}
}
}
*/
6 changes: 3 additions & 3 deletions src/main/java/dev/openfga/sdk/api/client/OpenFgaClient.java
Original file line number Diff line number Diff line change
Expand Up @@ -1131,7 +1131,7 @@ public CompletableFuture<ClientListObjectsResponse> listObjects(
* @return CompletableFuture<Void> that completes when streaming finishes
* @throws FgaInvalidParameterException When the Store ID is null, empty, or whitespace, or consumer is null
*/
public CompletableFuture<Void> streamedListObjects(
private CompletableFuture<Void> streamedListObjects(
ClientListObjectsRequest request, Consumer<StreamedListObjectsResponse> consumer)
throws FgaInvalidParameterException {
if (consumer == null) {
Expand Down Expand Up @@ -1171,7 +1171,7 @@ public CompletableFuture<Void> streamedListObjects(
* @return CompletableFuture<Void> that completes when streaming finishes
* @throws FgaInvalidParameterException When the Store ID is null, empty, or whitespace, or consumer is null
*/
public CompletableFuture<Void> streamedListObjects(
private CompletableFuture<Void> streamedListObjects(
ClientListObjectsRequest request,
ClientStreamedListObjectsOptions options,
Consumer<StreamedListObjectsResponse> consumer)
Expand Down Expand Up @@ -1211,7 +1211,7 @@ public CompletableFuture<Void> streamedListObjects(
* @return CompletableFuture<Void> that completes when streaming finishes or exceptionally on error
* @throws FgaInvalidParameterException When the Store ID is null, empty, or whitespace, or consumer is null
*/
public CompletableFuture<Void> streamedListObjects(
private CompletableFuture<Void> streamedListObjects(
ClientListObjectsRequest request,
ClientStreamedListObjectsOptions options,
Consumer<StreamedListObjectsResponse> consumer,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,6 @@
import java.nio.file.Files;
import java.nio.file.Paths;
import java.util.List;
import java.util.concurrent.CompletableFuture;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
Expand Down Expand Up @@ -373,6 +372,9 @@ private String writeAuthModel(String storeId) throws Exception {
return response.getAuthorizationModelId();
}

// NOTE: This test is temporarily commented out as the streamedListObjects API is not yet available for public use.
// It will be enabled in a future release.
/*
@Test
public void streamedListObjects() throws Exception {
// Given - Create a single store for all streaming tests
Expand Down Expand Up @@ -464,6 +466,7 @@ public void streamedListObjects() throws Exception {
assertEquals(20, chainTestObjects.size());
assertTrue(chainedOperationExecuted.get());
}
*/

/** Get the name of the test that invokes this function. Returned in the form: "$class.$fn" */
private String thisTestName() {
Expand Down
Loading
Loading