- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 3,517 for receivers (0.24 sec)
-
test/interface/receiver1.go
Robert Griesemer <******@****.***> 1606873032 -0800
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Dec 03 17:55:56 UTC 2020 - 790 bytes - Viewed (0) -
src/time/time.go
minWall = wallToInternal // year 1885 nsecMask = 1<<30 - 1 nsecShift = 30 ) // These helpers for manipulating the wall and monotonic clock readings // take pointer receivers, even when they don't modify the time, // to make them cheaper to call. // nsec returns the time's nanoseconds. func (t *Time) nsec() int32 { return int32(t.wall & nsecMask) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 50.7K bytes - Viewed (0) -
test/typeparam/orderedmap.go
// the receiver stops reading them. func _Ranger[Elem any]() (*_Sender[Elem], *_Receiver[Elem]) { c := make(chan Elem) d := make(chan struct{}) s := &_Sender[Elem]{ values: c, done: d, } r := &_Receiver[Elem]{ values: c, done: d, } runtime.SetFinalizer(r, (*_Receiver[Elem]).finalize) return s, r } // A _Sender is used to send values to a Receiver. type _Sender[Elem any] struct {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 01 19:45:34 UTC 2022 - 7.1K bytes - Viewed (0) -
pkg/scheduler/framework/parallelize/error_channel.go
// cancel function. func (e *ErrorChannel) SendErrorWithCancel(err error, cancel context.CancelFunc) { e.SendError(err) cancel() } // ReceiveError receives an error from channel without blocking on the receiver. func (e *ErrorChannel) ReceiveError() error { select { case err := <-e.errCh: return err default: return nil } } // NewErrorChannel returns a new ErrorChannel.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 20 17:39:23 UTC 2021 - 1.6K bytes - Viewed (0) -
cmd/admin-handlers.go
return } setEventStreamHeaders(w) // Trace Publisher and peer-trace-client uses nonblocking send and hence does not wait for slow receivers. // Keep 100k buffered channel. // If receiver cannot keep up with that we drop events. traceCh := make(chan []byte, 100000) peers, _ := newPeerRestClients(globalEndpoints)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 98K bytes - Viewed (0) -
src/internal/types/testdata/check/chans.go
// Ranger returns a Sender and a Receiver. The Receiver provides a // Next method to retrieve values. The Sender provides a Send method // to send values and a Close method to stop sending values. The Next // method indicates when the Sender has been closed, and the Send // method indicates when the Receiver has been freed. // // This is a convenient way to exit a goroutine sending values when // the receiver stops reading them.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 02 02:58:32 UTC 2022 - 1.7K bytes - Viewed (0) -
build-logic/kotlin-dsl/src/main/kotlin/gradlebuild.kotlin-dsl-sam-with-receiver.gradle.kts
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ plugins { id("kotlin-sam-with-receiver") } samWithReceiver { annotation("org.gradle.api.HasImplicitReceiver")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Dec 09 08:14:05 UTC 2020 - 738 bytes - Viewed (0) -
src/go/parser/testdata/chans.go2
// Ranger returns a Sender and a Receiver. The Receiver provides a // Next method to retrieve values. The Sender provides a Send method // to send values and a Close method to stop sending values. The Next // method indicates when the Sender has been closed, and the Send // method indicates when the Receiver has been freed. // // This is a convenient way to exit a goroutine sending values when // the receiver stops reading them.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 24 19:44:06 UTC 2020 - 1.7K bytes - Viewed (0) -
src/cmd/compile/internal/syntax/testdata/chans.go
func Ranger[T any]() (*Sender[T], *Receiver[T]) { c := make(chan T) d := make(chan bool) s := &Sender[T]{values: c, done: d} r := &Receiver[T]{values: c, done: d} runtime.SetFinalizer(r, r.finalize) return s, r } // A sender is used to send values to a Receiver. type Sender[T any] struct { values chan<- T done <-chan bool }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 30 18:02:18 UTC 2022 - 1.8K bytes - Viewed (0) -
doc/go1.17_spec.html
A method declaration binds an identifier, the <i>method name</i>, to a method, and associates the method with the receiver's <i>base type</i>. </p> <pre class="ebnf"> MethodDecl = "func" Receiver MethodName Signature [ FunctionBody ] . Receiver = Parameters . </pre> <p> The receiver is specified via an extra parameter section preceding the method
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 11 20:22:45 UTC 2024 - 211.6K bytes - Viewed (0)