} else {
            // No auto-applied plugins available
            return PluginRequests.EMPTY;
        }

    }

            on { this.pluginManager } doReturn pluginManager
        }
        val initialRequests = mock<PluginRequests>(name = "initialRequests")
        val autoAppliedPlugins = mock<PluginRequests>(name = "autoAppliedPlugins")
        val autoAppliedPluginHandler = mock<AutoAppliedPluginHandler> {
            on { getAutoAppliedPlugins(initialRequests, target) } doReturn autoAppliedPlugins
        }

        target: PluginAwareInternal,
        targetScope: ClassLoaderScope
    ) {
        val initialRequests = pluginRequests ?: PluginRequests.EMPTY
        val autoAppliedPlugins = autoAppliedPluginHandler.getAutoAppliedPlugins(initialRequests, target)
        pluginRequestApplicator.applyPlugins(
            initialRequests.mergeWith(autoAppliedPlugins),
            scriptHandler,
            target.pluginManager,

	type testDesc struct {
		desc             string
		initialRequests  []*discovery.DiscoveryRequest
		excludedResource string
		validator        func(testCase) error
	}

	descs := []testDesc{
		{
			desc:            "stream-no-resources",
			initialRequests: []*discovery.DiscoveryRequest{},
		},
		{
			desc: "stream-2-unnamed-resources",
			initialRequests: []*discovery.DiscoveryRequest{
				{
					TypeUrl: "foo",

    /**
     * Returns plugin requests that should be auto-applied
     * based on user requests, the current build invocation and the given target.
     */
    PluginRequests getAutoAppliedPlugins(PluginRequests initialRequests, Object pluginTarget);

				initialRequestsSent.Store(true)
				// Fire of a configured initial request, if there is one
				p.connectedMutex.RLock()
				initialRequest := p.initialDeltaHealthRequest
				if initialRequest != nil {
					con.sendDeltaRequest(initialRequest)
				}
				p.connectedMutex.RUnlock()
			}
		}
	}()

	defer func() {
		_ = con.upstreamDeltas.CloseSend()
	}()
	for {
		select {

				initialRequestsSent.Store(true)
				// Fire of a configured initial request, if there is one
				p.connectedMutex.RLock()
				initialRequest := p.initialHealthRequest
				if initialRequest != nil {
					con.sendRequest(initialRequest)
				}
				p.connectedMutex.RUnlock()
			}
		}
	}()

	defer con.upstream.CloseSend() // nolint
	for {
		select {