- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 2,444 for Receive (0.31 sec)
-
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/dispatch/Receive.java
* A source for messages. Implementations do not have to be thread-safe. */ public interface Receive<T> { /** * Blocks until the next message is available. Returns null when the end of the message stream has been reached. * * @return The next message, or null when the end of the stream has been reached. */ @Nullable T receive();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 1K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/client/DaemonClientConnectionTest.groovy
0 * staleAddressDetector._ } def "handles failed receive"() { def failure = new FooException() given: 1 * delegate.receive() >> Stub(Message) delegate.receive() >> { throw failure } when: connection.receive() connection.receive() then: def ex = thrown(DaemonConnectionException)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 3.8K bytes - Viewed (0) -
test/chan/perm.go
_ = x case cr <- 0: // ERROR "send" case x := <-cr: // ok _ = x case cs <- 0: // ok case x := <-cs: // ERROR "receive" _ = x } for _ = range cs { // ERROR "receive" } for range cs { // ERROR "receive" } close(c) close(cs) close(cr) // ERROR "receive" close(n) // ERROR "invalid operation.*non-chan type|must be channel|non-channel"
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jul 14 23:33:46 UTC 2021 - 1.4K bytes - Viewed (0) -
tests/test_custom_middleware_exception.py
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Thu Aug 25 21:44:40 UTC 2022 - 2.8K bytes - Viewed (0) -
platforms/core-configuration/declarative-dsl-provider/src/main/kotlin/org/gradle/internal/declarativedsl/conventions/conventions.kt
} } /** * A convention that applies a nested object access operation (e.g. foo { }). */ class NestedObjectAccessConvention(private val nestedObjectAccessRecord: NestedObjectAccessRecord) : Convention<NestedObjectAccessRecordConventionReceiver> { override fun apply(receiver: NestedObjectAccessRecordConventionReceiver) { receiver.receive(nestedObjectAccessRecord) } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 30 12:25:47 UTC 2024 - 2.4K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/locklistener/FileLockCommunicatorTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:49 UTC 2024 - 3.7K bytes - Viewed (0) -
test/fixedbugs/issue25958.go
package p // Verify that the "must be receive" error for "case done:" appears // on the line of the case clause, not the line of the done declaration. func f(done chan struct{}) { select { case done: // ERROR "must be receive|expected .*<-.* or .*=|must be send or receive|not used" case (chan struct{})(done): // ERROR "must be receive|expected .*<-.* or .*=|must be send or receive" }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jan 11 02:26:58 UTC 2022 - 570 bytes - Viewed (0) -
src/internal/types/testdata/fixedbugs/issue43671.go
func _[T any](ch T) { <-ch // ERRORx `cannot receive from ch .* \(no core type\)` } func _[T C0](ch T) { <-ch // ERROR "cannot receive from non-channel ch" } func _[T C1](ch T) { <-ch } func _[T C2](ch T) { <-ch } func _[T C3](ch T) { <-ch // ERRORx `cannot receive from ch .* \(no core type\)` } func _[T C4](ch T) { <-ch // ERROR "cannot receive from send-only channel" }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jan 17 19:54:27 UTC 2023 - 1.1K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/client/ReportStatusDispatcherTest.groovy
def "ignores failed dispatch and does not receive"() { given: def message = new ReportStatus(UUID.randomUUID(), "TOKEN".bytes) connection.dispatch(message) >> { throw new RuntimeException("Cannot dispatch") } when: dispatcher.dispatch(connection, message) then: 0 * connection.receive() noExceptionThrown() }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 1.7K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/client/StopDispatcherTest.groovy
def "ignores failed dispatch and does not receive"() { given: def message = new Stop(UUID.randomUUID()) connection.dispatch(message) >> { throw new RuntimeException("Cannot dispatch") } when: dispatcher.dispatch(connection, message) then: 0 * connection.receive() noExceptionThrown() } def "ignores failed receive"() { given:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 1.6K bytes - Viewed (0)