* trailers are available to read.
   *
   * It is not safe to call this concurrently with code that is processing the response body. If you
   * call this without consuming the complete response body, any remaining bytes in the response
   * body will be discarded before trailers are returned.
   *
   * If [Call.cancel] is called while this is blocking, this call will immediately throw.
   *

}

// BucketOptions provides options for ListBuckets and GetBucketInfo call.
type BucketOptions struct {
	Deleted    bool // true only when site replication is enabled
	Cached     bool // true only when we are requesting a cached response instead of hitting the disk for example ListBuckets() call.
	NoMetadata bool
}

    }

    /**
     * Adds a name/value pair to the formatted output in {@code name=value} format. If {@code value}
     * is {@code null}, the string {@code "null"} is used, unless {@link #omitNullValues()} is
     * called, in which case this name/value pair will not be added.
     */
    @CanIgnoreReturnValue
    public ToStringHelper add(String name, @Nullable Object value) {
      return addHolder(name, value);
    }

    /**

        return new BiMapEntry(entry);
      }

      @Override
      public void remove() {
        if (entry == null) {
          throw new IllegalStateException("no calls to next() since the last call to remove()");
        }
        V value = entry.getValue();
        iterator.remove();
        removeFromInverseMap(value);
        entry = null;
      }
    };
  }

  @WeakOuter

          boolean firstCall = true;

          @Override
          public boolean processBytes(byte[] buf, int off, int len) throws IOException {
            assertTrue("consume() called twice", firstCall);
            firstCall = false;
            return false;
          }

          @Override
          public @Nullable Void getResult() {
            return null;
          }

        promise.then(response -> latch.countDown()).error(error -> latch.countDown());

        assertTrue("Should complete within timeout", latch.await(ASYNC_TIMEOUT_SECONDS, TimeUnit.SECONDS));
        assertTrue("Close should be called", closeCalled.get());
    }

    // ============================================================
    // Tests for delete operations error handling
    // ============================================================

// 'req' will not be used after the call and caller can reuse.
// If no deadline is set on ctx, a 1-minute deadline will be added.
func (c *Connection) Request(ctx context.Context, h HandlerID, req []byte) ([]byte, error) {
	if !h.valid() {
		return nil, ErrUnknownHandler
	}
	if c.State() != StateConnected {
		return nil, ErrDisconnected
	}
	// Create mux client and call.
	client, err := c.newMuxClient(ctx)

        assertEquals(Integer.MIN_VALUE, searchRenderData.getCurrentPageNumber());
    }

    @Test
    public void test_nullSafety() {
        // Ensure all getters return appropriate values when setters haven't been called
        SearchRenderData freshData = new SearchRenderData();

        // These should return null
        assertNull(freshData.getDocumentItems());
        assertNull(freshData.getFacetResponse());

    @JvmName("shouldRunBrokenForConfigurationCacheDocsTests") get() = gradleProperty(RUN_BROKEN_CONFIGURATION_CACHE_DOCS_TESTS).orNull.toBoolean()


/**
 * Is a promotion build task called?
 */
val Project.isPromotionBuild: Boolean
    get() {
        val taskNames = gradle.startParameter.taskNames
        return taskNames.contains("promotionBuild") ||

        dataMap.put("test", "value");

        // Execute
        Map<String, Object> result = indexUpdateCallback.ingest(paramMap, dataMap);

        // Verify ingester was called
        assertEquals(1, ingester.processCalled);
        assertEquals("processed", result.get("status"));
    }

    @Test
    public void test_ingest_withException() {