writer.close();

    assertTrue(sink.wasStreamClosed());
    assertThat(sink.getString()).isEqualTo(STRING);
  }

  public void testWrite_string() throws IOException {
    assertThat(sink.getString()).isEqualTo("");
    sink.write(STRING);

    assertTrue(sink.wasStreamOpened() && sink.wasStreamClosed());
    assertThat(sink.getString()).isEqualTo(STRING);
  }

  public void testWriteFrom_reader() throws IOException {

    deps = [
        ":c_api_macros_hdrs",
        "@xla//xla/tsl/c:tsl_status_headers",
    ],
)

cc_library(
    name = "tf_tstring",
    srcs = [
        "tf_tstring.cc",
    ],
    hdrs = [
        "tf_tstring.h",
    ],
    copts = tf_copts(),
    visibility = ["//visibility:public"],
    deps = [
        ":c_api_macros_hdrs",
        ":tf_datatype_hdrs",

     * @see ResourceBundle#getString(String)
     */
    public static String getString(final ResourceBundle bundle, final String key) {
        assertArgumentNotNull("bundle", bundle);
        assertArgumentNotEmpty("key", key);

        try {
            return bundle.getString(key);
        } catch (final Throwable t) {
            return null;
        }
    }

  }

  private static final String TEST_STRING = "a test string";

  /** invokeAny(c) returns result of some task in c if at least one completes */
  public void testInvokeAnyImpl() throws Exception {
    ListeningExecutorService e = newDirectExecutorService();
    try {
      List<Callable<String>> l = new ArrayList<>();
      l.add(() -> TEST_STRING);
      l.add(() -> TEST_STRING);

  EXPECT_EQ(0, TF_NumDims(t_out));
  ASSERT_EQ(TF_TensorByteSize(t_in.get()), TF_TensorByteSize(t_out));
  TF_TString* t_in_tstr = static_cast<TF_TString*>(TF_TensorData(t_in.get()));
  TF_TString* t_out_tstr = static_cast<TF_TString*>(TF_TensorData(t_out));
  EXPECT_EQ(absl::string_view(test_string),
            absl::string_view(TF_TString_GetDataPointer(t_out_tstr),
                              TF_TString_GetSize(t_out_tstr)));

            }
        };

        String[] testStrings = { "simple", "with spaces", "special!@#$%^&*()", "unicode_test", "", "very long string " + "x".repeat(100) };

        for (String testStr : testStrings) {
            String encrypted = cipher.encrypt(testStr);
            String decrypted = cipher.decrypt(encrypted);

  }

  private static final String TEST_STRING = "a test string";

  /** invokeAny(c) returns result of some task in c if at least one completes */
  public void testInvokeAnyImpl() throws Exception {
    ListeningExecutorService e = newDirectExecutorService();
    try {
      List<Callable<String>> l = new ArrayList<>();
      l.add(() -> TEST_STRING);
      l.add(() -> TEST_STRING);

    tensorflow/c/tf_attrtype.h \
    tensorflow/c/tf_buffer.h  \
    tensorflow/c/tf_datatype.h \
    tensorflow/c/tf_status.h \
    tensorflow/c/tf_tensor.h \
    tensorflow/c/tf_tensor_helper.h \
    tensorflow/c/tf_tstring.h \
    tensorflow/c/tf_file_statistics.h \
    tensorflow/c/tensor_interface.h \
    tensorflow/c/c_api_macros.h \
    tensorflow/c/c_api_experimental.h \
    ${LIB_PKG}/include/tensorflow/c

     * @throws RuntimeException If failed (and not due source not exists).
     */
    @Nonnull
    default Optional<String> getString(@Nonnull URI relativeSource) {
        return getString(relativeSource, StandardCharsets.UTF_8);
    }

    /**
     * PUTs the source file (must exist as file) to target URI. The target MUST BE relative from the

     * @throws IllegalAccessRuntimeException {@link IllegalAccessException} if an error occurs
     * @see #getString(Field, Object)
     */
    public static String getString(final Field field) throws IllegalAccessRuntimeException {
        assertArgumentNotNull("field", field);

        return getString(field, null);
    }

    /**
     * Returns the value of a {@link Field} as a {@link String}.
     *