- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 3,454 for sreceiver (6.16 sec)
-
pkg/client/tests/portfoward_test.go
// read from the client received := make([]byte, len(pf.expected[port])) n, err := stream.Read(received) if err != nil { return fmt.Errorf("error reading from client for port %d: %v", port, err) } if n != len(pf.expected[port]) { return fmt.Errorf("unexpected length read from client for port %d: got %d, expected %d. data=%q", port, n, len(pf.expected[port]), string(received)) } // store the received content
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 05 06:08:18 UTC 2023 - 7.1K bytes - Viewed (0) -
test/method.go
promotion() } type A struct{ B } type B struct { C *D } type C int func (C) f() {} // value receiver, direct field of A func (*C) g() {} // pointer receiver type D int func (D) h() {} // value receiver, indirect field of A func (*D) i() {} // pointer receiver func expectPanic() { if r := recover(); r == nil { panic("expected nil dereference") } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 11 23:20:52 UTC 2013 - 5.2K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/Connection.java
import org.gradle.internal.dispatch.Receive; /** * <p>A messaging endpoint which allows push-style dispatch and pull-style receive. * * <p>Implementations are not guaranteed to be completely thread-safe. * However, the implementations: * <ul> * <li>should allow separate threads for dispatching and receiving, i.e. single thread that dispatches * and a different single thread that receives should be perfectly safe</li>
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 1.4K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DefaultDaemonConnection.java
// 2. Stop the connection. This means that the thread receiving from the connection will receive a null and finish up. // 3. Stop receiving incoming messages. Blocks until the receive thread has finished. This will notify the stdin and receive queues to signal end of input. // 4. Stop the receive queue, to unblock any threads blocked in receive().
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:51:37 UTC 2024 - 16K bytes - Viewed (0) -
docs/en/docs/tutorial/encoder.md
Let's imagine that you have a database `fake_db` that only receives JSON compatible data. For example, it doesn't receive `datetime` objects, as those are not compatible with JSON. So, a `datetime` object would have to be converted to a `str` containing the data in <a href="https://en.wikipedia.org/wiki/ISO_8601" class="external-link" target="_blank">ISO format</a>.
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Tue Oct 17 05:59:11 UTC 2023 - 1.8K bytes - Viewed (0) -
LICENSE
reinstated, you do not qualify to receive new licenses for the same material under section 10. 9. Acceptance Not Required for Having Copies. You are not required to accept this License in order to receive or run a copy of the Program. Ancillary propagation of a covered work occurring solely as a consequence of using peer-to-peer transmission to receive a copy likewise does not require acceptance. However,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Apr 23 18:58:53 UTC 2021 - 33.7K bytes - Viewed (0) -
internal/grid/msg.go
// m.Payload is length 0, but not nil. func (m *message) setZeroPayloadFlag() { m.Flags &^= FlagPayloadIsZero if len(m.Payload) == 0 && m.Payload != nil { m.Flags |= FlagPayloadIsZero } } type receiver interface { msgp.Unmarshaler Op() Op } type sender interface { msgp.MarshalSizer Op() Op } type connectReq struct { ID [16]byte Host string }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Nov 28 19:22:29 UTC 2023 - 7.3K bytes - Viewed (0) -
platforms/ide/tooling-api/src/main/java/org/gradle/tooling/StreamedValueListener.java
* limitations under the License. */ package org.gradle.tooling; import org.gradle.api.Incubating; /** * Receives a value sent via {@link BuildController#send(Object)}. * * <p>Objects are received in the order they were sent and all objects are received before the result of the {@link BuildAction} is returned to the application.</p> * * @since 8.6 */ @Incubating
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Dec 19 08:15:25 UTC 2023 - 1.1K bytes - Viewed (0) -
src/go/types/signature.go
fallthrough // continue with first receiver case 1: recv = recvList[0] } sig.recv = recv // Delay validation of receiver type as it may cause premature expansion // of types the receiver type is dependent on (see issues go.dev/issue/51232, go.dev/issue/51233). check.later(func() { // spec: "The receiver type must be of the form T or *T where T is a type name."
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Feb 29 22:06:18 UTC 2024 - 13K bytes - Viewed (0) -
subprojects/build-events/src/test/groovy/org/gradle/internal/build/event/DefaultBuildEventsListenerRegistryTest.groovy
cleanup: signalBuildFinished() } def "listeners receive events concurrently"() { def listener1 = { thread.blockUntil.received instant.handled } as OperationCompletionListener def listener2 = { instant.received thread.blockUntil.handled } as OperationCompletionListener when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 02:21:10 UTC 2024 - 8K bytes - Viewed (0)