}
        }

        // Assert: consumer called exactly for the 3 known codes, with the right arguments
        ArgumentCaptor<Integer> dosCaptor = ArgumentCaptor.forClass(Integer.class);
        ArgumentCaptor<Integer> ntCaptor = ArgumentCaptor.forClass(Integer.class);
        verify(consumer, times(3)).accept(dosCaptor.capture(), ntCaptor.capture());

                        "parameters": [
                            {
                                "required": True,
                                "schema": {"title": "Item Id", "type": "integer"},
                                "name": "item_id",
                                "in": "path",
                            }
                        ],
                    }
                },

  protected static final int EXCEPTION_DATA = -1;
  protected static final int VALID_INPUT_DATA = 1;
  protected static final Exception EXCEPTION = new Exception("Test exception");

  protected SettableFuture<Integer> inputFuture;
  protected ListenableFuture<T> resultFuture;
  protected MockFutureListener listener;

  @Override
  protected void setUp() throws Exception {
    super.setUp();

    ExecutorService executor = newDirectExecutorService();
    ThreadLocal<Integer> threadLocalCount =
        new ThreadLocal<Integer>() {
          @Override
          protected Integer initialValue() {
            return 0;
          }
        };

    Callable<Integer> incrementTask =
        () -> {
          int i = threadLocalCount.get();
          threadLocalCount.set(i + 1);

abstract class AbstractAbstractFutureTest extends TestCase {
  @SuppressWarnings("initialization.field.uninitialized")
  private TestedFuture<@Nullable Integer> future;

  @SuppressWarnings("initialization.field.uninitialized")
  private AbstractFuture<@Nullable Integer> delegate;

  abstract AbstractFuture<@Nullable Integer> newDelegate();

  @Override
  protected void setUp() {
    future = TestedFuture.create();
    delegate = newDelegate();
  }

        super(AvPair.MsvAvFlags, raw);
    }

    /**
     * Constructs an AV flags pair from integer flags
     * @param flags the flag values as integer
     */
    public AvFlags(final int flags) {
        this(encode(flags));
    }

    /**
     * Gets the flags as an integer value
     * @return flags
     */
    public int getFlags() {
        return SMBUtil.readInt4(this.getRaw(), 0);
    }

            return 30;
        }

        @Override
        public Integer getSuggestUpdateRequestIntervalAsInteger() {
            return 1000;
        }

        @Override
        public Integer getSuggestUpdateDocPerRequestAsInteger() {
            return 100;
        }

        @Override
        public Integer getSuggestSourceReaderScrollSizeAsInteger() {
            return 1000;
        }

	CSRRCI	$1, TIME, (X15)			// ERROR "needs an integer register output"
	CSRRS	(X10), CYCLE, X5		// ERROR "integer register or immediate expected for 1st operand"
	CSRRS	X0, CYCLE, (X10)		// ERROR "needs an integer register output"
	CSRRS	X0, TU, X5			// ERROR "unknown CSR"
	CSRRS	X0, CYCLE			// ERROR "missing CSR name"
	CSRRS	$-1, TIME, X15			// ERROR "immediate out of range 0 to 31"
	CSRRSI	$32, TIME, X15			// ERROR "immediate out of range 0 to 31"

  public void testComplexBuilder() {
    List<Integer> colorElem = asList(0x00, 0x33, 0x66, 0x99, 0xCC, 0xFF);
    // javac won't compile this without "this.<Integer>"
    ImmutableSet.Builder<Integer> webSafeColorsBuilder = this.<Integer>builder();
    for (Integer red : colorElem) {
      for (Integer green : colorElem) {
        for (Integer blue : colorElem) {

  }

  public void testRecursiveComputation() throws InterruptedException {
    AtomicReference<LoadingCache<Integer, String>> cacheRef = new AtomicReference<>();
    CacheLoader<Integer, String> recursiveLoader =
        new CacheLoader<Integer, String>() {
          @Override
          public String load(Integer key) {
            if (key > 0) {
              return key + ", " + cacheRef.get().getUnchecked(key - 1);