Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 930 for onText (0.05 sec)

  1. build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/docbook/BasicJavadocLexer.java

                        scanner.next();
                    }
                }
    
                visitor.onText(text.toString());
            }
            visitor.onEnd();
        }
    
        private void skipComment() {
            scanner.next(4);
            while (!scanner.isEmpty() && !scanner.lookingAt(END_HTML_COMMENT)) {
                scanner.next();
            }
            if (!scanner.isEmpty()) {
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Mon Aug 19 15:07:24 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  2. istioctl/pkg/cli/context.go

    	"istio.io/istio/istioctl/pkg/util/handlers"
    	"istio.io/istio/pkg/cluster"
    	"istio.io/istio/pkg/kube"
    	"istio.io/istio/pkg/maps"
    	"istio.io/istio/pkg/ptr"
    	"istio.io/istio/pkg/slices"
    )
    
    type Context interface {
    	// CLIClient returns a client for the default revision
    	CLIClient() (kube.CLIClient, error)
    	// CLIClientWithRevision returns a client for the given revision
    	CLIClientWithRevision(rev string) (kube.CLIClient, error)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 23 19:31:32 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  3. compat/maven-model-builder/src/main/java/org/apache/maven/model/building/FileToRawModelMerger.java

                DependencyManagement source,
                boolean sourceDominant,
                Map<Object, Object> context) {
            Iterator<Dependency> sourceIterator = source.getDependencies().iterator();
            builder.dependencies(target.getDependencies().stream()
                    .map(d -> mergeDependency(d, sourceIterator.next(), sourceDominant, context))
                    .collect(Collectors.toList()));
        }
    
        @Override
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  4. internal/dsync/dsync_test.go

    	dm.Unlock(context.Background())
    }
    
    func TestSimpleLockUnlockMultipleTimes(t *testing.T) {
    	dm := NewDRWMutex(ds, "test")
    
    	dm.Lock(id, source)
    	time.Sleep(time.Duration(10+(rand.Float32()*50)) * time.Millisecond)
    	dm.Unlock(context.Background())
    
    	dm.Lock(id, source)
    	time.Sleep(time.Duration(10+(rand.Float32()*50)) * time.Millisecond)
    	dm.Unlock(context.Background())
    
    	dm.Lock(id, source)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 19 14:35:19 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  5. internal/s3select/jstream/decoder.go

    		switch c := d.next(); c {
    		case '\n':
    			d.lineStart = d.pos
    			d.lineNo++
    			continue
    		case ' ', '\t', '\r':
    			continue
    		default:
    			return c
    		}
    	}
    	return 0
    }
    
    // create syntax errors at current position, with optional context
    func (d *Decoder) mkError(err DecoderError, context ...string) error {
    	if len(context) > 0 {
    		err.context = context[0]
    	}
    	err.atChar = d.cur()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  6. cni/pkg/nodeagent/net_test.go

    	assert.Equal(t, nil, netns)
    
    	// run gc to clean up ns:
    
    	//revive:disable-next-line:call-to-gc Just a test that we are cleaning up the netns
    	runtime.GC()
    	assertNSClosed(t, closed)
    }
    
    func TestServerRemovePodAlwaysRemovesIPSetEntryEvenOnFail(t *testing.T) {
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    	setupLogging()
    	fixture := getTestFixure(ctx)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Jul 25 16:13:38 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  7. cmd/data-scanner.go

    func (d *dynamicSleeper) Timer(ctx context.Context) func() {
    	t := time.Now()
    	return func() {
    		doneAt := time.Now()
    		d.Sleep(ctx, doneAt.Sub(t))
    	}
    }
    
    // Sleep sleeps the specified time multiplied by the sleep factor.
    // If the factor is updated the sleep will be done again with the new factor.
    func (d *dynamicSleeper) Sleep(ctx context.Context, base time.Duration) {
    	for {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
  8. cmd/erasure-decode.go

    	p.readers = tmp
    	// next is the next non-preferred index.
    	next := 0
    	for i, ok := range prefer {
    		if !ok || p.readers[i] == nil {
    			continue
    		}
    		if i == next {
    			next++
    			continue
    		}
    		// Move reader with index i to index next.
    		// Do this by swapping next and i
    		p.readers[next], p.readers[i] = p.readers[i], p.readers[next]
    		p.readerToBuf[next] = i
    		p.readerToBuf[i] = next
    		next++
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  9. cmd/jwt_test.go

    	b.ResetTimer()
    	b.ReportAllocs()
    	b.RunParallel(func(pb *testing.PB) {
    		for pb.Next() {
    			err = xjwt.ParseWithStandardClaims(token, xjwt.NewStandardClaims(), []byte(creds.SecretKey))
    			if err != nil {
    				b.Fatal(err)
    			}
    		}
    	})
    }
    
    func BenchmarkParseJWTMapClaims(b *testing.B) {
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    
    	obj, fsDir, err := prepareFS(ctx)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 22 07:04:48 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  10. internal/grid/stream.go

    	// Canceling the context will cause the context cancellation error to be returned.
    	responses <-chan Response
    	cancel    context.CancelCauseFunc
    
    	// Requests sent to the server.
    	// If the handler is defined with 0 incoming capacity this will be nil.
    	// Channel *must* be closed to signal the end of the stream.
    	// If the request context is canceled, the stream will no longer process requests.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 3.1K bytes
    - Viewed (0)
Back to top