Search Options

Results per page
Sort
Preferred Languages
Advance

Results 231 - 240 of 409 for Callback (0.09 sec)

  1. docs/debugging/xl-meta/main.go

    			}
    			s += "}"
    		}
    		res = append(res, []byte(s)...)
    	}
    	res = append(res, '}')
    	return res, nil
    }
    
    // files returns files as callback.
    func (x xlMetaInlineData) files(fn func(name string, data []byte)) error {
    	if len(x) == 0 {
    		return nil
    	}
    	if !x.versionOK() {
    		return errors.New("xlMetaInlineData: unknown version")
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 05 11:57:44 UTC 2024
    - 40.3K bytes
    - Viewed (0)
  2. docs/changelogs/changelog_4x.md

        scheduling. In your debugger you will see new thread names and more use of daemon threads.
    
     *  Fix: Don't drop callbacks on unexpected exceptions. When an interceptor throws an unchecked
        exception the callback is now notified that the call was canceled. The exception is still sent
        to the uncaught exception handler for reporting and recovery.
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 17 13:25:31 UTC 2024
    - 25.2K bytes
    - Viewed (0)
  3. internal/grid/handlers.go

    	// If the request context is canceled, the stream will no longer process requests.
    	Requests chan<- Req
    }
    
    // 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 *TypedStream[Req, Resp]) Results(next func(resp Resp) error) (err error) {
    	return s.responses.Results(func(b []byte) error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 27.7K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/internal/http2/Http2Test.kt

        frame.writeByte(99) // type 99
        frame.writeByte(FLAG_NONE)
        frame.writeInt(expectedStreamId)
        frame.writeInt(111111111) // custom data
        reader.nextFrame(requireSettings = false, BaseTestHandler()) // Should not callback.
      }
    
      @Test fun onlyOneLiteralHeadersFrame() {
        val sentHeaders = headerEntries("name", "value")
        val headerBytes = literalHeaders(sentHeaders)
        writeMedium(frame, headerBytes.size.toInt())
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  5. internal/dsync/drwmutex.go

    				noQuorum, err := refreshLock(ctx, dm.clnt, id, source, quorum)
    				if err == nil && noQuorum {
    					// Clean the lock locally and in remote nodes
    					forceUnlock(ctx, dm.clnt, id)
    					// Execute the caller lock loss callback
    					if lockLossCallback != nil {
    						lockLossCallback()
    					}
    					return
    				}
    
    				refreshTimer.Reset(dm.refreshInterval)
    			}
    		}
    	}()
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 15:49:49 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  6. docs/fr/docs/async.md

    Dans les versions précédentes de Javascript NodeJS / Navigateur, vous auriez utilisé des "callbacks". Menant potentiellement à ce que l'on appelle <a href="http://callbackhell.com/" class="external-link" target="_blank">le "callback hell"</a>.
    
    
    ## Coroutines
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 25.4K bytes
    - Viewed (0)
  7. tensorflow/c/eager/c_api_experimental.h

    // Cancellation APIs.
    
    typedef struct TFE_CancellationManager TFE_CancellationManager;
    typedef int64_t TFE_CancellationToken;
    typedef struct TFE_CancelCallback {
      void (*callback)(void* context);
      void* context;
    } TFE_CancelCallback;
    TF_CAPI_EXPORT extern TFE_CancellationManager* TFE_NewCancellationManager();
    TF_CAPI_EXPORT extern bool TFE_CancellationManagerIsCancelled(
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Wed Feb 21 22:37:46 UTC 2024
    - 39.5K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

           * Atomically reschedules this task and assigns the new future to {@link
           * #cancellationDelegate}.
           */
          @CanIgnoreReturnValue
          public Cancellable reschedule() {
            // invoke the callback outside the lock, prevents some shenanigans.
            Schedule schedule;
            try {
              schedule = CustomScheduler.this.getNextSchedule();
            } catch (Throwable t) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 16:22:21 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  9. guava/src/com/google/common/util/concurrent/MoreExecutors.java

       *   <li>If an exception propagates out of a {@code Runnable}, it is not necessarily seen by any
       *       {@code UncaughtExceptionHandler} for the thread. For example, if the callback passed to
       *       {@link Futures#addCallback} throws an exception, that exception will be typically be
       *       logged by the {@link ListenableFuture} implementation, even if the thread is configured
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 44.1K bytes
    - Viewed (0)
  10. docs/en/docs/async.md

    In previous versions of NodeJS / Browser JavaScript, you would have used "callbacks". Which leads to <a href="http://callbackhell.com/" class="external-link" target="_blank">callback hell</a>.
    
    ## Coroutines
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Wed Aug 28 23:33:37 UTC 2024
    - 23.5K bytes
    - Viewed (0)
Back to top