google.golang.org/grpc/internal/buffer.Unbounded.Get (method)

3 uses

	google.golang.org/grpc/internal/buffer (current package)
		unbounded.go#L98: func (b *Unbounded) Get() <-chan any {

	google.golang.org/grpc/internal/grpcsync
		callback_serializer.go#L92: 		case cb := <-cs.callbacks.Get():
		callback_serializer.go#L102: 	for cb := range cs.callbacks.Get() {