Search Options

Results per page
Sort
Preferred Languages
Advance

Results 171 - 180 of 770 for NEXT (0.02 sec)

  1. guava/src/com/google/common/eventbus/Dispatcher.java

            try {
              Event nextEvent;
              while ((nextEvent = queueForThread.poll()) != null) {
                while (nextEvent.subscribers.hasNext()) {
                  nextEvent.subscribers.next().dispatchEvent(nextEvent.event);
                }
              }
            } finally {
              dispatching.remove();
              queue.remove();
            }
          }
        }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Dec 15 19:31:54 UTC 2023
    - 7.3K bytes
    - Viewed (0)
  2. compat/maven-compat/src/test/java/org/apache/maven/artifact/resolver/ArtifactResolverTest.java

            printErrors(result);
    
            Iterator<Artifact> i = result.getArtifacts().iterator();
            assertEquals(n, i.next(), "n should be first");
            assertEquals(m, i.next(), "m should be second");
    
            // inverse order
            set = new LinkedHashSet<>();
            set.add(m);
            set.add(n);
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  3. internal/grid/stream.go

    }
    
    // Results returns the results from the remote server one by one.
    // If any error is returned by the callback, the stream will be canceled.
    // If the context is canceled, the stream will be canceled.
    func (s *Stream) Results(next func(b []byte) error) (err error) {
    	done := false
    	defer func() {
    		if s.cancel != nil {
    			s.cancel(err)
    		}
    
    		if !done {
    			// Drain channel.
    			for range s.responses {
    			}
    		}
    	}()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  4. src/main/java/jcifs/DfsReferralData.java

    
        /**
         * @return the expiration time of this entry
         */
        long getExpiration ();
    
    
        /**
         * 
         * @return pointer to next referral, points to self if there is no further referral
         */
        DfsReferralData next ();
    
    
        /**
         * @return the link
         */
        String getLink ();
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 1.9K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/collect/ListsTest.java

        assertTrue(iterator.hasNext());
        assertEquals("1", iterator.next());
        assertTrue(iterator.hasNext());
        assertEquals("2", iterator.next());
        assertTrue(iterator.hasNext());
        assertEquals("3", iterator.next());
        assertTrue(iterator.hasNext());
        assertEquals("4", iterator.next());
        assertFalse(iterator.hasNext());
        try {
          iterator.next();
          fail("did not detect end of list");
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 35K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/collect/ListsTest.java

        assertTrue(iterator.hasNext());
        assertEquals("1", iterator.next());
        assertTrue(iterator.hasNext());
        assertEquals("2", iterator.next());
        assertTrue(iterator.hasNext());
        assertEquals("3", iterator.next());
        assertTrue(iterator.hasNext());
        assertEquals("4", iterator.next());
        assertFalse(iterator.hasNext());
        try {
          iterator.next();
          fail("did not detect end of list");
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 35K bytes
    - Viewed (0)
  7. docs/en/docs/advanced/openapi-callbacks.md

    ///
    
    The only new thing is the `callbacks=invoices_callback_router.routes` as an argument to the *path operation decorator*. We'll see what that is next.
    
    ## Documenting the callback
    
    The actual callback code will depend heavily on your own API app.
    
    And it will probably vary a lot from one app to the next.
    
    It could be just one or two lines of code, like:
    
    ```Python
    callback_url = "https://example.com/api/v1/invoices/events/"
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/collect/SetsTest.java

        assertEquals(ImmutableSet.of(), i.next());
        assertEquals(ImmutableSet.of(1), i.next());
        assertEquals(ImmutableSet.of(2), i.next());
        assertEquals(ImmutableSet.of(2, 1), i.next());
        assertEquals(ImmutableSet.of(3), i.next());
        assertEquals(ImmutableSet.of(3, 1), i.next());
        assertEquals(ImmutableSet.of(3, 2), i.next());
        assertEquals(ImmutableSet.of(3, 2, 1), i.next());
        assertFalse(i.hasNext());
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 48.6K bytes
    - Viewed (0)
  9. cmd/metacache-stream.go

    	if err == io.EOF {
    		err = io.ErrUnexpectedEOF
    	}
    	r.err = err
    	return r.current, err
    }
    
    // next will read one entry from the stream.
    // Generally not recommended for fast operation.
    func (r *metacacheReader) next() (metaCacheEntry, error) {
    	r.checkInit()
    	if r.err != nil {
    		return metaCacheEntry{}, r.err
    	}
    	var m metaCacheEntry
    	var err error
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 19.5K bytes
    - Viewed (0)
  10. src/main/java/jcifs/internal/smb2/ServerMessageBlock2Response.java

         */
        @Override
        public void prepare ( CommonServerMessageBlockRequest next ) {
            CommonServerMessageBlockResponse n = getNextResponse();
            if ( n != null ) {
                n.prepare(next);
            }
        }
    
    
        /**
         * {@inheritDoc}
         *
         * @see jcifs.internal.smb2.ServerMessageBlock2#reset()
         */
        @Override
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Aug 05 09:45:59 UTC 2018
    - 7.4K bytes
    - Viewed (0)
Back to top