- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 412 for dispatchTo (0.14 sec)
-
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/queue/MultiEndPointQueue.java
* See the License for the specific language governing permissions and * limitations under the License. */ package org.gradle.internal.remote.internal.hub.queue; import org.gradle.internal.dispatch.Dispatch; import org.gradle.internal.remote.internal.hub.protocol.EndOfStream; import org.gradle.internal.remote.internal.hub.protocol.InterHubMessage; import java.util.ArrayDeque; import java.util.ArrayList;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 3.9K bytes - Viewed (0) -
src/runtime/asm_mips64x.s
DISPATCH(runtime·call256, 256) DISPATCH(runtime·call512, 512) DISPATCH(runtime·call1024, 1024) DISPATCH(runtime·call2048, 2048) DISPATCH(runtime·call4096, 4096) DISPATCH(runtime·call8192, 8192) DISPATCH(runtime·call16384, 16384) DISPATCH(runtime·call32768, 32768) DISPATCH(runtime·call65536, 65536) DISPATCH(runtime·call131072, 131072) DISPATCH(runtime·call262144, 262144) DISPATCH(runtime·call524288, 524288)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Nov 06 19:45:59 UTC 2023 - 24.3K bytes - Viewed (0) -
platforms/core-runtime/logging/src/main/java/org/gradle/internal/logging/sink/LogEventDispatcher.java
if (event.getLogLevel() == null) { dispatch(event, stdoutChain); dispatch(event, stderrChain); } else if (event.getLogLevel() == LogLevel.ERROR) { dispatch(event, stderrChain); } else { dispatch(event, stdoutChain); } } protected void dispatch(OutputEvent event, OutputEventListener listener) { if (listener != null) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:05:18 UTC 2023 - 1.7K bytes - Viewed (0) -
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/MockWebServer.kt
var bodyLimit: Long by delegate::bodyLimit var serverSocketFactory: ServerSocketFactory? by delegate::serverSocketFactory var dispatcher: Dispatcher = QueueDispatcher() set(value) { field = value delegate.dispatcher = value.wrap() } val port: Int get() { before() // This implicitly starts the delegate. return delegate.port }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Tue Jan 23 14:31:42 UTC 2024 - 5.9K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/client/DaemonClientConnection.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 30 06:43:50 UTC 2024 - 4.2K bytes - Viewed (0) -
src/runtime/asm_riscv64.s
MOVWU frameSize+32(FP), T0 DISPATCH(runtime·call16, 16) DISPATCH(runtime·call32, 32) DISPATCH(runtime·call64, 64) DISPATCH(runtime·call128, 128) DISPATCH(runtime·call256, 256) DISPATCH(runtime·call512, 512) DISPATCH(runtime·call1024, 1024) DISPATCH(runtime·call2048, 2048) DISPATCH(runtime·call4096, 4096) DISPATCH(runtime·call8192, 8192) DISPATCH(runtime·call16384, 16384)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Nov 09 13:57:06 UTC 2023 - 27K bytes - Viewed (0) -
src/runtime/asm_s390x.s
DISPATCH(runtime·call512, 512) DISPATCH(runtime·call1024, 1024) DISPATCH(runtime·call2048, 2048) DISPATCH(runtime·call4096, 4096) DISPATCH(runtime·call8192, 8192) DISPATCH(runtime·call16384, 16384) DISPATCH(runtime·call32768, 32768) DISPATCH(runtime·call65536, 65536) DISPATCH(runtime·call131072, 131072) DISPATCH(runtime·call262144, 262144) DISPATCH(runtime·call524288, 524288)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jan 25 09:18:28 UTC 2024 - 28.1K bytes - Viewed (0) -
analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/components/KtFirImportOptimizer.kt
} /** * Returns correct importable name for implicitly dispatched callable - that is, a callable * which has a dispatch receiver, but whose dispatch receiver is present implicitly. The most * important case for that is the following: * * ```kt * import MyObject.bar
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Fri Jun 07 16:54:07 UTC 2024 - 24.7K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/tooling/internal/provider/PhasedActionEventConsumerTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 2.7K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/client/ReportDaemonStatusClientTest.groovy
1 * connection.dispatch({it instanceof ReportStatus}) 1 * connection.receive() >> new Success(new Status(12345, "3.0", "BOGUS")) 1 * connection.dispatch({it instanceof Finished}) 1 * connection.stop() and: 1 * connector.maybeConnect(daemon2) >>> connection _ * connection.daemon >> daemon2 1 * connection.dispatch({it instanceof ReportStatus})
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 4.7K bytes - Viewed (0)