- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for StreamCompletion (0.17 sec)
-
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/dispatch/StreamCompletion.java
* See the License for the specific language governing permissions and * limitations under the License. */ package org.gradle.internal.dispatch; public interface StreamCompletion { /** * Signals the end of the stream of messages. */ void endStream();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 782 bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/hub/MessageHubBackedObjectConnectionTest.groovy
*/ package org.gradle.internal.remote.internal.hub import org.gradle.api.GradleException import org.gradle.internal.dispatch.MethodInvocation import org.gradle.internal.dispatch.StreamCompletion import org.gradle.internal.remote.internal.ConnectCompletion import org.gradle.internal.remote.internal.TestConnection import org.gradle.internal.remote.internal.hub.protocol.ChannelIdentifier
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 4K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/MessageHubBackedObjectConnection.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 7.5K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/worker/request/Receiver.java
package org.gradle.process.internal.worker.request; import org.gradle.api.NonNullApi; import org.gradle.api.problems.internal.Problem; import org.gradle.internal.UncheckedException; import org.gradle.internal.dispatch.StreamCompletion; import org.gradle.internal.logging.events.LogEvent; import org.gradle.internal.logging.events.OutputEventListener; import org.gradle.internal.logging.events.StyledTextOutputEvent;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Mar 06 13:26:04 UTC 2024 - 4.8K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/dispatch/BoundedDispatch.java
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. */ @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 1K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/worker/request/WorkerAction.java
import org.gradle.internal.Cast; import org.gradle.internal.UncheckedException; import org.gradle.internal.concurrent.Stoppable; import org.gradle.internal.dispatch.StreamCompletion; import org.gradle.internal.event.DefaultListenerManager; import org.gradle.internal.instantiation.InstantiatorFactory; import org.gradle.internal.instantiation.generator.DefaultInstantiatorFactory;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Mar 27 08:22:48 UTC 2024 - 7.4K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/ObjectConnectionBuilder.java
* thread-safe. Messages are delivered to the handler by a single thread. * * <p>A handler instance may also implement {@link org.gradle.internal.dispatch.StreamCompletion}, in which case it will be notified when no further messages will be forwarded to it.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 2.8K bytes - Viewed (0) -
testing/architecture-test/src/changes/archunit-store/internal-api-nullability.txt
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 967.9K bytes - Viewed (0)