Search Options

Results per page
Sort
Preferred Languages
Advance

Results 301 - 310 of 887 for closure (0.07 sec)

  1. guava-tests/test/com/google/common/io/MultiInputStreamTest.java

                  throw new IllegalStateException("More than one source open");
                }
                return new FilterInputStream(source.openStream()) {
                  @Override
                  public void close() throws IOException {
                    super.close();
                    counter[0]--;
                  }
                };
              }
            };
        byte[] result = ByteSource.concat(checker, checker, checker).read();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 4.6K bytes
    - Viewed (0)
  2. cmd/post-policy-fan-out.go

    			if err != nil {
    				errs[idx] = err
    				return
    			}
    
    			reader := NewPutObjReader(hr)
    			defer func() {
    				if err := reader.Close(); err != nil {
    					errs[idx] = err
    				}
    				if err := hr.Close(); err != nil {
    					errs[idx] = err
    				}
    			}()
    
    			userDefined := make(map[string]string, len(req.UserMetadata))
    			for k, v := range req.UserMetadata {
    				userDefined[k] = v
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2ExchangeCodec.kt

        stream = http2Connection.newStream(requestHeaders, hasRequestBody)
        // We may have been asked to cancel while creating the new stream and sending the request
        // headers, but there was still no stream to close.
        if (canceled) {
          stream!!.closeLater(ErrorCode.CANCEL)
          throw IOException("Canceled")
        }
        stream!!.readTimeout().timeout(chain.readTimeoutMillis.toLong(), TimeUnit.MILLISECONDS)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketExtensions.kt

     * `server_max_window_bits`. This harms our ability to support these parameters:
     *
     *  * If `client_max_window_bits` is less than 15, OkHttp must close the web socket with code 1010.
     *    Otherwise it would compress values in a way that servers could not decompress.
     *  * If `server_max_window_bits` is less than 15, OkHttp will waste memory on an oversized buffer.
     *
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  5. internal/event/target/nsq.go

    	}
    
    	if err := target.send(eventData); err != nil {
    		return err
    	}
    
    	// Delete the event from store.
    	return target.store.Del(key)
    }
    
    // Close - closes underneath connections to NSQD server.
    func (target *NSQTarget) Close() (err error) {
    	close(target.quitCh)
    	if target.producer != nil {
    		// this blocks until complete:
    		target.producer.Stop()
    	}
    	return nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  6. internal/event/target/mqtt.go

    	_, err := target.isActive()
    	if err != nil {
    		return err
    	}
    
    	return target.send(eventData)
    }
    
    // Close - does nothing and available for interface compatibility.
    func (target *MQTTTarget) Close() error {
    	if target.client != nil {
    		target.client.Disconnect(100)
    	}
    	close(target.quitCh)
    	return nil
    }
    
    func (target *MQTTTarget) init() error {
    	return target.initOnce.Do(target.initMQTT)
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt

              windowSizeIncrement = increment,
            ),
          )
        }
        handler.windowUpdate(streamId, increment)
      }
    
      @Throws(IOException::class)
      override fun close() {
        source.close()
      }
    
      /**
       * Decompression of the header block occurs above the framing layer. This class lazily reads
       * continuation frames as they are needed by [Hpack.Reader.readHeaders].
       */
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 19.9K bytes
    - Viewed (0)
  8. src/cmd/asm/internal/lex/lex.go

    	// SetBase sets the position base.
    	SetBase(*src.PosBase)
    	// Line reports the source line number of the token.
    	Line() int
    	// Col reports the source column number of the token.
    	Col() int
    	// Close does any teardown required.
    	Close()
    }
    
    // A Token is a scan token plus its string value.
    // A macro is stored as a sequence of Tokens with spaces stripped.
    type Token struct {
    	ScanToken
    	text string
    }
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Aug 29 18:31:05 UTC 2023
    - 4.1K bytes
    - Viewed (0)
  9. internal/http/check_port_linux.go

    	l, err := lc.Listen(ctx, "tcp", net.JoinHostPort(host, port))
    	if err != nil {
    		return err
    	}
    
    	// As we are able to listen on this network, the port is not in use.
    	// Close the listener and continue check other networks.
    	return l.Close()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 03 21:12:25 UTC 2023
    - 1.9K bytes
    - Viewed (0)
  10. docs_src/dependencies/tutorial010.py

    class MySuperContextManager:
        def __init__(self):
            self.db = DBSession()
    
        def __enter__(self):
            return self.db
    
        def __exit__(self, exc_type, exc_value, traceback):
            self.db.close()
    
    
    async def get_db():
        with MySuperContextManager() as db:
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Mar 26 19:09:53 UTC 2020
    - 292 bytes
    - Viewed (0)
Back to top