*
 * @deprecated since 4.0.0, use {@link org.apache.maven.api.services} instead
 */
@Deprecated(since = "4.0.0")
public class StringSource implements Source {
    private final String content;

    private final String location;

    private final int hashCode;

    /**
     * Creates a new source backed by the specified string.
     *
     * @param content The String representation, may be empty or {@code null}.

                addScopes(filter.getScopes());
            }
        }
    }

    private void addScopes(Collection<String> scopes) {
        if (scopes != null) {
            for (String scope : scopes) {
                addScope(scope);
            }
        }
    }

    private void addScope(String scope) {
        this.scopes.add(scope);

        addScopeInternal(scope);
    }

      }
  private val appVersion = 100
  private lateinit var journalFile: Path
  private lateinit var journalBkpFile: Path
  private val taskFaker = TaskFaker()
  private val taskRunner = taskFaker.taskRunner
  private lateinit var cache: DiskLruCache
  private val toClose = ArrayDeque<DiskLruCache>()

  private fun createNewCache() {
    createNewCacheWithSize(Int.MAX_VALUE)
  }

    /**
     * Test implementation of CreateContextResponse for testing purposes
     */
    static class TestCreateContextResponse implements CreateContextResponse {
        private byte[] name;
        private byte[] data;
        private int decodeCallCount = 0;
        private boolean throwOnDecode = false;

        public TestCreateContextResponse(byte[] name) {
            this.name = name;
        }

        @Override

            return "";
        }
    }

    private static RepositoryPolicy toPolicy(ArtifactRepositoryPolicy policy) {
        RepositoryPolicy result = null;
        if (policy != null) {
            result = new RepositoryPolicy(policy.isEnabled(), policy.getUpdatePolicy(), policy.getChecksumPolicy());
        }
        return result;
    }

        }

        return binding;
    }

    private static final AtomicInteger call_id = new AtomicInteger(1);

    private final DcerpcBinding binding;
    private final int max_xmit = 4280;
    private final int max_recv = this.max_xmit;
    private int state = 0;
    private DcerpcSecurityProvider securityProvider = null;
    private final CIFSContext transportContext;

    /**

        when(parentLocator.isWorkgroup()).thenReturn(true);
    }

    /** Simple implementation of FileEntry for controlled inputs in tests. */
    private static final class StubFileEntry implements FileEntry {
        private final String name;
        private final int type;

        StubFileEntry(String name, int type) {
            this.name = name;
            this.type = type;
        }

        @Override

    }

    /**
     * Test resource for tracking
     */
    static class TestResource implements AutoCloseable {
        private final AtomicBoolean closed = new AtomicBoolean(false);
        private final String name;

        TestResource(String name) {
            this.name = name;
        }

        @Override
        public void close() {
            closed.set(true);
        }

    }

    // Helper methods to write data to byte arrays for testing read methods
    private void writeInt2(int val, byte[] dst, int dstIndex) {
        dst[dstIndex] = (byte) val;
        dst[dstIndex + 1] = (byte) (val >> 8);
    }

    private void writeInt4(int val, byte[] dst, int dstIndex) {
        dst[dstIndex] = (byte) val;
        dst[dstIndex + 1] = (byte) (val >> 8);

@NullMarked
@GwtCompatible
public class FuturesTest extends TestCase {
  private static final Logger aggregateFutureLogger =
      Logger.getLogger(AggregateFuture.class.getName());
  private final TestLogHandler aggregateFutureLogHandler = new TestLogHandler();

  private static final String DATA1 = "data";
  private static final String DATA2 = "more data";
  private static final String DATA3 = "most data";

  @Override