* governing permissions and limitations under the License.
 */
package org.codelibs.fess.crawler.util;

import java.io.IOException;
import java.io.InputStream;

/**
 * This inputstream ignores a close method.
 *
 * @author shinsuke
 *
 */
public class IgnoreCloseInputStream extends InputStream {

    private transient InputStream inputStream;

    public IgnoreCloseInputStream(final InputStream inputStream) {

	if err != nil {
		return false
	}
	return mediaType == "multipart/form-data" && r.Method == http.MethodPost
}

// Verify if the request has AWS Streaming Signature Version '4'. This is only valid for 'PUT' operation.
func isRequestSignStreamingV4(r *http.Request) bool {
	return r.Header.Get(xhttp.AmzContentSha256) == streamingContentSHA256 &&
		r.Method == http.MethodPut
}

                    ioe.printStackTrace( log );
                }
            }
        }
    }

    /* Build a connection. Only one thread will ever call this method at
     * any one time. If this method throws an exception or the connect timeout
     * expires an encapsulating TransportException will be thrown from connect
     * and the transport will be in error.
     */

            final SearchRequestBuilder builder = c.prepareSearch(index);
            callback.accept(builder);
            builder.setFetchSource(new String[] { "parentUrl", "method", "mimeType", "sessionId", "url", "executionTime", "createTime",
                    "contentLength", "lastModified", "ruleId", "httpStatusCode", "status" }, null);
            return builder.execute();
        });

         * @return {@code this} for method call chaining
         */
        @Nonnull
        public DependencyResolverRequestBuilder pathTypeFilter(@Nonnull Predicate<PathType> pathTypeFilter) {
            this.pathTypeFilter = pathTypeFilter;
            return this;
        }

        /**
         * Specifies the type of paths to include in the result. This is a convenience method for

 */
package mockwebserver3

import okhttp3.ExperimentalOkHttpApi
import okhttp3.Headers

/** An HTTP request initiated by the server. */
@ExperimentalOkHttpApi
class PushPromise(
  val method: String,
  val path: String,
  val headers: Headers,
  val response: MockResponse,

 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package com.google.common.util.concurrent;


/**
 * Tests for {@link Monitor}'s interruptible methods.
 *
 * @author Justin T. Sampson
 */
public class InterruptibleMonitorTest extends MonitorTestCase {

  public InterruptibleMonitorTest() {
    super(true);
  }

 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package com.google.common.base;

/** Class containing an unannotated Java method for use from {@code OptionalExtensionsTest}. */
final class UnannotatedJavaClass {
  static Object getNull() {
    return null;
  }

  private UnannotatedJavaClass() {}

 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package com.google.common.util.concurrent;


/**
 * Tests for {@link Monitor}'s interruptible methods.
 *
 * @author Justin T. Sampson
 */
public class InterruptibleMonitorTest extends MonitorTestCase {

  public InterruptibleMonitorTest() {
    super(true);
  }

 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package com.google.common.util.concurrent;


/**
 * Tests for {@link Monitor}'s uninterruptible methods.
 *
 * @author Justin T. Sampson
 */
public class UninterruptibleMonitorTest extends MonitorTestCase {

  public UninterruptibleMonitorTest() {
    super(false);
  }