Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 124 for discord (0.2 sec)

  1. cmd/streaming-signature-v4.go

    	cred, seedSignature, region, seedDate, errCode := calculateSeedSignature(req, trailer)
    	if errCode != ErrNone {
    		return nil, errCode
    	}
    
    	if trailer {
    		// Discard anything unsigned.
    		req.Trailer = make(http.Header)
    		trailers := req.Header.Values(awsTrailerHeader)
    		for _, key := range trailers {
    			req.Trailer.Add(key, "")
    		}
    	} else {
    		req.Trailer = nil
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 18.2K bytes
    - Viewed (0)
  2. src/archive/tar/reader_test.go

    				}
    				cnt++
    				if s2 == "manual" {
    					if _, err = tr.writeTo(io.Discard); err != nil {
    						break
    					}
    				}
    			}
    			if err != v.err {
    				t.Errorf("test %d, NewReader(%s) with %s discard: got %v, want %v",
    					i, s1, s2, err, v.err)
    			}
    			if cnt != v.cnt {
    				t.Errorf("test %d, NewReader(%s) with %s discard: got %d headers, want %d headers",
    					i, s1, s2, cnt, v.cnt)
    			}
    		}
    	}
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Mon Nov 21 21:14:38 GMT 2022
    - 47.1K bytes
    - Viewed (0)
  3. cmd/admin-handlers-users_test.go

    	r, err := client.GetObject(ctx, bucket, object, minio.GetObjectOptions{})
    	if err != nil {
    		c.Fatalf("user was unable to download the object: %v", err)
    	}
    	defer r.Close()
    
    	_, err = io.Copy(io.Discard, r)
    	if err != nil {
    		c.Fatalf("user was unable to download the object: %v", err)
    	}
    }
    
    func (c *check) mustHeadObject(ctx context.Context, client *minio.Client, bucket, object string, tagCount int) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 12 16:36:16 GMT 2024
    - 45.7K bytes
    - Viewed (0)
  4. statement.go

    				writer.WriteByte('(')
    				stmt.AddVar(writer, v...)
    				writer.WriteByte(')')
    			} else {
    				writer.WriteString("(NULL)")
    			}
    		case *DB:
    			subdb := v.Session(&Session{Logger: logger.Discard, DryRun: true}).getInstance()
    			if v.Statement.SQL.Len() > 0 {
    				var (
    					vars = subdb.Statement.Vars
    					sql  = v.Statement.SQL.String()
    				)
    
    Go
    - Registered: Sun May 05 09:35:13 GMT 2024
    - Last Modified: Fri Jan 12 08:42:21 GMT 2024
    - 19.8K bytes
    - Viewed (0)
  5. cmd/admin-heal-ops.go

    			// unconsumedTimer fires.
    			select {
    			// Check after a second
    			case <-time.After(time.Second):
    				h.mutex.Unlock()
    				continue
    
    			case <-h.ctx.Done():
    				h.mutex.Unlock()
    				// discard result and return.
    				return errHealStopSignalled
    
    			// Timeout if no results consumed for too long.
    			case <-unconsumedTimer.C:
    				h.mutex.Unlock()
    				return errHealIdleTimeout
    			}
    		}
    		break
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.1K bytes
    - Viewed (1)
  6. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt

          TYPE_GOAWAY -> readGoAway(handler, length, flags, streamId)
          TYPE_WINDOW_UPDATE -> readWindowUpdate(handler, length, flags, streamId)
          else -> source.skip(length.toLong()) // Implementations MUST discard frames of unknown types.
        }
    
        return true
      }
    
      @Throws(IOException::class)
      private fun readHeaders(
        handler: Handler,
        length: Int,
        flags: Int,
        streamId: Int,
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 19.9K bytes
    - Viewed (0)
  7. api/go1.19.txt

    pkg io/ioutil, func ReadFile //deprecated #42026
    pkg io/ioutil, func TempDir //deprecated #42026
    pkg io/ioutil, func TempFile //deprecated #42026
    pkg io/ioutil, func WriteFile //deprecated #42026
    Plain Text
    - Registered: Tue May 07 11:14:38 GMT 2024
    - Last Modified: Fri Dec 02 16:29:41 GMT 2022
    - 17.9K bytes
    - Viewed (1)
  8. docs/es/docs/async.md

    * los datos enviados por tu programa para ser recibidos por el cliente a través de la red
    * el contenido de un archivo en disco para ser leído por el sistema y entregado al programa
    * los contenidos que tu programa da al sistema para ser escritos en disco
    * una operación relacionada con una API remota
    * una operación de base de datos
    * el retorno de resultados de una consulta de base de datos
    * etc.
    
    Plain Text
    - Registered: Sun May 05 07:19:11 GMT 2024
    - Last Modified: Thu Apr 18 19:53:19 GMT 2024
    - 24.9K bytes
    - Viewed (0)
  9. guava/src/com/google/common/base/Throwables.java

       *
       * <p>Prefer this method instead of manually casting an exception's cause. For example, {@code
       * (IOException) e.getCause()} throws a {@link ClassCastException} that discards the original
       * exception {@code e} if the cause is not an {@link IOException}, but {@code
       * Throwables.getCauseAs(e, IOException.class)} keeps {@code e} as the {@link
       * ClassCastException}'s cause.
       *
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Wed Mar 06 15:38:58 GMT 2024
    - 20.6K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/base/Throwables.java

       *
       * <p>Prefer this method instead of manually casting an exception's cause. For example, {@code
       * (IOException) e.getCause()} throws a {@link ClassCastException} that discards the original
       * exception {@code e} if the cause is not an {@link IOException}, but {@code
       * Throwables.getCauseAs(e, IOException.class)} keeps {@code e} as the {@link
       * ClassCastException}'s cause.
       *
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Mar 06 15:38:58 GMT 2024
    - 20.6K bytes
    - Viewed (0)
Back to top