/**
 * GWt emulation of {@link RegularImmutableMap}.
 *
 * @author Hayward Chan
 */
final class RegularImmutableMap<K, V> extends ForwardingImmutableMap<K, V> {

  static final ImmutableMap<Object, Object> EMPTY = new RegularImmutableMap<Object, Object>();

  RegularImmutableMap(Map<? extends K, ? extends V> delegate) {
    super(delegate);
  }

  RegularImmutableMap(Entry<? extends K, ? extends V>... entries) {

      throws ExecutionException {
    try {
      return future.get();
    } catch (InterruptedException e) {
      // Should never be thrown in GWT but play it safe
      throw new IllegalStateException(e);
    }
  }

 * possibly closed.
 *
 * @author Colin Decker
 */
@NullUnmarked
public interface TestStreamSupplier {

  /** Returns whether or not a new stream was opened. */
  boolean wasStreamOpened();

  /** Returns whether or not an open stream was closed. */
  boolean wasStreamClosed();

 */
@GwtCompatible
@NullUnmarked
public class UntrustedInputFutureTest extends AbstractAbstractFutureTest {
  @Override
  AbstractFuture<@Nullable Integer> newDelegate() {
    AbstractFuture<@Nullable Integer> future = new AbstractFuture<@Nullable Integer>() {};
    assertFalse(future instanceof TrustedFuture); // sanity check
    return future;
  }

import org.apache.maven.eventspy.EventSpy;

/**
 * DefaultEventSpyContext
 */
@Deprecated
public class DefaultEventSpyContext implements EventSpy.Context {

    private final Map<String, Object> data = new HashMap<>();

    @Override
    public Map<String, Object> getData() {
        return data;
    }

/**
 * Wagon for testing, for protocol <code>a</code>
 *
 */
@Named("a")
@Singleton
public class WagonA extends WagonMock {
    public String[] getSupportedProtocols() {
        return new String[] {"a"};
    }

/**
 * Wagon for testing, for protocols <code>b1</code> and <code>b2</code>
 *
 */
@Named("b")
@Singleton
public class WagonB extends WagonMock {
    public String[] getSupportedProtocols() {
        return new String[] {"b1", "b2"};
    }

/**
 * Wagon for testing, for protocol <code>c</code>
 *
 */
@Named("c")
@Singleton
public class WagonC extends WagonMock {
    public String[] getSupportedProtocols() {
        return new String[] {"c"};
    }

package once

// Singleton contains a pointer to T that must be set once.
// Until the value is set all Get() calls will block.
type Singleton[T any] struct {
	v   *T
	set chan struct{}
}

// NewSingleton creates a new unset singleton.
func NewSingleton[T any]() *Singleton[T] {
	return &Singleton[T]{set: make(chan struct{}), v: nil}
}

// Get will return the singleton value.
func (s *Singleton[T]) Get() *T {
	<-s.set
	return s.v

        DuplicateHostCQ cq = new DuplicateHostCQ();
        queryLambda.callback(cq);
        final Collection<FilterFunctionBuilder> list = new ArrayList<>();
        if (functionsLambda != null) {
            functionsLambda.callback((cqLambda, scoreFunctionBuilder) -> {
                DuplicateHostCQ cf = new DuplicateHostCQ();
                cqLambda.callback(cf);