*/

package org.gradle.internal.dispatch;

/**
 * A sink for a bounded stream of messages.
 *
 * <p>Implementations are not required to be thread-safe.
 */
public interface BoundedDispatch<T> extends Dispatch<T>, StreamCompletion {
    /**
     * Signals the end of the stream of messages. No further messages should be dispatched using the {@link Dispatch#dispatch(Object)} method after this method is called.
     */

            } else {
                dispatch = DISCARD;
            }
            BoundedDispatch<Object> boundedDispatch;
            if (dispatch instanceof BoundedDispatch) {
                boundedDispatch = Cast.uncheckedNonnullCast(dispatch);
            } else {
                boundedDispatch = DISCARD;
            }
            StreamFailureHandler streamFailureHandler;

 * limitations under the License.
 */

package org.gradle.internal.remote.internal.hub

import org.gradle.api.Action
import org.gradle.internal.dispatch.BoundedDispatch
import org.gradle.internal.dispatch.Dispatch
import org.gradle.internal.remote.internal.RemoteConnection
import org.gradle.internal.remote.internal.TestConnection

import org.gradle.internal.concurrent.CompositeStoppable;
import org.gradle.internal.concurrent.ExecutorFactory;
import org.gradle.internal.concurrent.ThreadSafe;
import org.gradle.internal.dispatch.BoundedDispatch;
import org.gradle.internal.dispatch.Dispatch;
import org.gradle.internal.dispatch.MethodInvocation;
import org.gradle.internal.dispatch.ProxyDispatchAdapter;
import org.gradle.internal.dispatch.ReflectionDispatch;

Class <org.gradle.internal.dispatch.BoundedDispatch> is not annotated (directly or via its package) with @org.gradle.api.NonNullApi in (BoundedDispatch.java:0)