Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  * Copyright 2014-2015, Inc. or its affiliates. All Rights Reserved.
  * Licensed under the Apache License, Version 2.0 (the "License").
  * You may not use this file except in compliance with the License.
  * A copy of the License is located at
 * or in the "license" file accompanying this file. This file is distributed
 * express or implied. See the License for the specific language governing
 * permissions and limitations under the License.
package com.amazonaws.internal;
import static com.amazonaws.util.SdkRuntime.shouldAbort;
Base class for AWS Java SDK specific
public abstract class SdkInputStream extends InputStream implements
        MetricAwareReleasable {
Returns the underlying input stream, if any, from the subclass; or null if there is no underlying input stream.
    abstract protected InputStream getWrappedInputStream();
    public final boolean isMetricActivated() {
        InputStream in = getWrappedInputStream();
        if (in instanceof MetricAware) {
            MetricAware metricAware = (MetricAware)in;
            return metricAware.isMetricActivated();
        return false;

Aborts with subclass specific abortion logic executed if needed. Note the interrupted status of the thread is cleared by this method.

com.amazonaws.AbortedException if found necessary.
    protected final void abortIfNeeded() {
        if (shouldAbort()) {
            try {
                abort();    // execute subclass specific abortion logic
            } catch (IOException e) {
            throw new AbortedException();

Can be used to provide abortion logic prior to throwing the AbortedException. No-op by default.
    protected void abort() throws IOException {
        // no-op by default, but subclass such as S3ObjectInputStream may override

WARNING: Subclass that overrides this method must NOT call super.release() or else it would lead to infinite loop.

    public void release() {
        // Don't call IOUtils.release(in, null) or else could lead to infinite loop
        InputStream in = getWrappedInputStream();
        if (in instanceof Releasable) {
            // This allows any underlying stream that has the close operation
            // disabled to be truly released
            Releasable r = (Releasable)in;
New to GrepCode? Check out our FAQ X