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

package org.gradle.internal.remote.internal;

import org.gradle.internal.concurrent.Stoppable;
import org.gradle.internal.dispatch.Dispatch;
import org.gradle.internal.dispatch.Receive;

/**
 * <p>A messaging endpoint which allows push-style dispatch and pull-style receive.
 *

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

package org.gradle.tooling.internal.consumer.connection;

import org.gradle.internal.concurrent.Stoppable;
import org.gradle.tooling.BuildAction;
import org.gradle.tooling.internal.consumer.PhasedBuildAction;
import org.gradle.tooling.internal.consumer.TestExecutionRequest;

import org.gradle.internal.classpath.InstrumentedExecutionAccess
import org.gradle.internal.concurrent.Stoppable
import org.gradle.internal.service.scopes.ListenerService


@ListenerService
internal
class InstrumentedExecutionAccessListenerRegistry(
    instrumentedExecutionAccessListener: InstrumentedExecutionAccessListener
) : Stoppable {

    init {
        InstrumentedExecutionAccess.setListener(instrumentedExecutionAccessListener)

 */
package org.gradle.api.internal.artifacts.verification.signatures;

import org.gradle.internal.concurrent.Stoppable;
import org.gradle.security.internal.PublicKeyService;

import java.io.File;
import java.util.Set;

public interface SignatureVerificationService extends Stoppable {
    void verify(File origin, File signature, Set<String> trustedKeys, Set<String> ignoredKeys, SignatureVerificationResultBuilder result);

 * limitations under the License.
 */

package org.gradle.api.internal.tasks.testing;

import org.gradle.internal.concurrent.Stoppable;

/**
 * A processor for executing tests. Implementations are not required to be thread-safe.
 */
public interface TestClassProcessor extends Stoppable {
    /**
     * Performs any initialisation which this processor needs to perform.
     *

 * limitations under the License.
 */
package org.gradle.kotlin.dsl.provider

import org.gradle.internal.concurrent.Stoppable
import java.util.Collections.synchronizedList


open class ClassPathModeExceptionCollector : Stoppable {

    private
    val collection: MutableList<Exception> = synchronizedList(mutableListOf<Exception>())

    val exceptions: List<Exception>

 * limitations under the License.
 */

package org.gradle.tooling.internal.consumer.connection;

import org.gradle.internal.concurrent.Stoppable;

/**
 * Implementations must be thread-safe.
 */
public interface ConsumerActionExecutor extends Stoppable {
    /**
     * Blocks until all actions have completed.
     */
    @Override
    void stop();

    String getDisplayName();

import org.gradle.api.logging.Logging;
import org.gradle.api.model.ObjectFactory;
import org.gradle.internal.Cast;
import org.gradle.internal.concurrent.CompositeStoppable;
import org.gradle.internal.concurrent.Stoppable;
import org.gradle.internal.operations.BuildOperationContext;
import org.gradle.internal.operations.BuildOperationDescriptor;
import org.gradle.internal.operations.BuildOperationRunner;

 * limitations under the License.
 */

package org.gradle.internal.resource.transport.sftp;

import com.jcraft.jsch.ChannelSftp;
import org.gradle.internal.concurrent.Stoppable;

public interface LockableSftpClient extends Stoppable {
    SftpHost getHost();
    ChannelSftp getSftpClient();
    boolean isConnected();

package org.gradle.internal.nativeintegration.services

import net.rubygrapefruit.platform.Native
import org.gradle.api.internal.file.temp.TemporaryFileProvider
import org.gradle.internal.Cast
import org.gradle.internal.concurrent.Stoppable
import org.gradle.internal.file.Chmod
import org.gradle.internal.reflect.JavaMethod
import org.gradle.internal.service.ServiceRegistration
import org.gradle.internal.service.ServiceRegistry
import org.slf4j.LoggerFactory