Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 54 for unbuffered (0.07 sec)

  1. internal/grid/benchmark_test.go

    					select {
    					case <-ctx.Done():
    						return nil
    					case out <- toSend:
    					}
    				}
    				return nil
    			},
    
    			Subroute:    "some-subroute",
    			OutCapacity: 1, // Only one message buffered.
    			InCapacity:  0,
    		}))
    		errFatal(err)
    	}
    	const payloadSize = 512
    	rng := rand.New(rand.NewSource(time.Now().UnixNano()))
    	payload := make([]byte, payloadSize)
    	_, err = rng.Read(payload)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  2. internal/pubsub/pubsub.go

    	// not atomics:
    	subs []*Sub[T]
    	sync.RWMutex
    }
    
    // Publish message to the subscribers.
    // Note that publish is always non-blocking send so that we don't block on slow receivers.
    // Hence receivers should use buffered channel so as not to miss the published events.
    func (ps *PubSub[T, M]) Publish(item T) {
    	ps.RLock()
    	defer ps.RUnlock()
    	for _, sub := range ps.subs {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Feb 06 16:57:30 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  3. cmd/listen-notification-handlers.go

    	setEventStreamHeaders(w)
    
    	// Listen Publisher and peer-listen-client uses nonblocking send and hence does not wait for slow receivers.
    	// Use buffered channel to take care of burst sends or slow w.Write()
    	mergeCh := make(chan []byte, globalAPIConfig.getRequestsPoolCapacity()*len(globalEndpoints.Hostnames()))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/http/RetryAndFollowUpInterceptor.kt

      /**
       * Report and attempt to recover from a failure to communicate with a server. Returns true if
       * `e` is recoverable, or false if the failure is permanent. Requests with a body can only
       * be recovered if the body is buffered or if the failure occurred before the request has been
       * sent.
       */
      private fun recover(
        e: IOException,
        call: RealCall,
        userRequest: Request,
        requestSendStarted: Boolean,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 15 13:24:48 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/io/Files.java

       *     helpful predefined constants
       * @return the buffered reader
       */
      public static BufferedReader newReader(File file, Charset charset) throws FileNotFoundException {
        checkNotNull(file);
        checkNotNull(charset);
        return new BufferedReader(new InputStreamReader(new FileInputStream(file), charset));
      }
    
      /**
       * Returns a buffered writer that writes to a file using the given character set.
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jul 22 19:03:12 UTC 2024
    - 33.1K bytes
    - Viewed (0)
  6. docs/changelogs/changelog_1x.md

     * Fix: Support SPDY header blocks with trailing bytes.
     * Fix: Allow `;` as separator for `Cache-Control` header.
     * Fix: Correct bug where HTTPS POST requests were always automatically buffered.
     * Fix: Honor read timeout when parsing SPDY headers.
    
    
    ## Version 1.2.1
    
    _2013-08-23_
    
     * Resolve issue with 'jar-with-dependencies' artifact creation.
     * Fix: Support empty SPDY header values.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 02:19:09 UTC 2022
    - 6.4K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/io/CharSink.java

       *
       * @throws IOException if an I/O error occurs while opening the writer
       */
      public abstract Writer openStream() throws IOException;
    
      /**
       * Opens a new buffered {@link Writer} for writing to this sink. The returned stream is not
       * required to be a {@link BufferedWriter} in order to allow implementations to simply delegate to
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 31 14:20:11 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt

            // that happens, then we will have buffered bytes that are needed by the SSLSocket!
            // This check is imperfect: it doesn't tell us whether a handshake will succeed, just
            // that it will almost certainly fail because the proxy has sent unexpected data.
            if (source?.buffer?.exhausted() == false || sink?.buffer?.exhausted() == false) {
              throw IOException("TLS tunnel buffered too many bytes!")
            }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 18.6K bytes
    - Viewed (0)
  9. guava/src/com/google/common/io/Files.java

       *     helpful predefined constants
       * @return the buffered reader
       */
      public static BufferedReader newReader(File file, Charset charset) throws FileNotFoundException {
        checkNotNull(file);
        checkNotNull(charset);
        return new BufferedReader(new InputStreamReader(new FileInputStream(file), charset));
      }
    
      /**
       * Returns a buffered writer that writes to a file using the given character set.
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jul 22 19:03:12 UTC 2024
    - 33.1K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/WebSocket.kt

       * doesn't include framing overhead. If compression is enabled, uncompressed messages size
       * is used to calculate this value. It also doesn't include any bytes buffered by the operating
       * system or network intermediaries. This method returns 0 if no messages are waiting in the
       * queue. If may return a nonzero value after the web socket has been canceled; this indicates
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.3K bytes
    - Viewed (0)
Back to top