public void close()

in playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/RefCountedContainer.java [45:58]

• 12 lines of code
• 4 McCabe index (conditional complexity)

    public void close() throws Exception {
      if (valid) {
        synchronized (lock) {
          refCounter -= 1;

          if (refCounter == 0 && value != null) {
            value.close();
            value = null;
          }
        }

        valid = false;
      }
    }