Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 327 for closing (0.06 sec)

  1. internal/event/target/nats.go

    	}
    
    	return target.store.Del(key)
    }
    
    // Close - closes underneath connections to NATS server.
    func (target *NATSTarget) Close() (err error) {
    	close(target.quitCh)
    	if target.stanConn != nil {
    		// closing the streaming connection does not close the provided NATS connection.
    		if target.stanConn.NatsConn() != nil {
    			target.stanConn.NatsConn().Close()
    		}
    		return target.stanConn.Close()
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  2. docs/de/docs/tutorial/dependencies/dependencies-with-yield.md

    # Abhängigkeiten mit yield
    
    FastAPI unterstützt Abhängigkeiten, die nach Abschluss einige <abbr title="Manchmal auch genannt „Exit Code“, „Cleanup Code“, „Teardown Code“, „Closing Code“, „Kontext Manager Exit Code“, usw.">zusätzliche Schritte ausführen</abbr>.
    
    Verwenden Sie dazu `yield` statt `return` und schreiben Sie die zusätzlichen Schritte / den zusätzlichen Code danach.
    
    /// tip | "Tipp"
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  3. internal/grid/connection.go

    		defer c.connMu.Unlock()
    		if c.debugInConn != nil {
    			if debugPrint {
    				fmt.Println("debug: closing inbound connection")
    			}
    			c.debugInConn.Close()
    		}
    	case debugKillOutbound:
    		c.connMu.Lock()
    		defer c.connMu.Unlock()
    		if c.debugInConn != nil {
    			if debugPrint {
    				fmt.Println("debug: closing outgoing connection")
    			}
    			c.debugInConn.Close()
    		}
    	case debugWaitForExit:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  4. cni/pkg/nodeagent/ztunnelserver.go

    // nolint: unparam
    func (z *ztunnelServer) handleConn(ctx context.Context, conn *ZtunnelConnection) error {
    	defer conn.Close()
    
    	context.AfterFunc(ctx, func() {
    		log.Debug("context cancelled, closing ztunnel server")
    		conn.Close()
    	})
    
    	// before doing anything, add the connection to the list of active connections
    	z.conns.addConn(conn)
    	defer z.conns.deleteConn(conn)
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Jul 29 16:08:35 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/Response.kt

     * An HTTP response. Instances of this class are not immutable: the response body is a one-shot
     * value that may be consumed only once and then closed. All other properties are immutable.
     *
     * This class implements [Closeable]. Closing it simply closes its response body. See
     * [ResponseBody] for an explanation and examples.
     */
    class Response internal constructor(
      /**
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jul 06 09:38:30 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  6. docs/en/docs/tutorial/dependencies/dependencies-with-yield.md

    # Dependencies with yield
    
    FastAPI supports dependencies that do some <abbr title='sometimes also called "exit code", "cleanup code", "teardown code", "closing code", "context manager exit code", etc.'>extra steps after finishing</abbr>.
    
    To do this, use `yield` instead of `return`, and write the extra steps (code) after.
    
    /// tip
    
    Make sure to use `yield` one single time per dependency.
    
    ///
    
    /// note | "Technical Details"
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 14K bytes
    - Viewed (0)
  7. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/ftp/FtpClient.java

        }
    
        @Override
        public void close() {
            if (ftpAuthenticationHolder == null) {
                return;
            }
            if (logger.isDebugEnabled()) {
                logger.debug("Closing FtpClient...");
            }
            ftpAuthenticationHolder = null;
            for (final FTPClient ftpClient : ftpClientQueue) {
                try {
                    ftpClient.disconnect();
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Sat Oct 12 01:41:37 UTC 2024
    - 25.7K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt

      /**
       * The reason why this stream was closed, or null if it closed normally or has not yet been
       * closed.
       *
       * If there are multiple reasons to abnormally close this stream (such as both peers closing it
       * near-simultaneously) then this is the first reason known to this peer.
       */
      internal var errorCode: ErrorCode? = null
        get() = this.withLock { field }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 23.2K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/collect/Streams.java

      }
    
      @SuppressWarnings("CatchingUnchecked") // sneaky checked exception
      private static void closeAll(BaseStream<?, ?>[] toClose) {
        // If one of the streams throws an exception, continue closing the others, then throw the
        // exception later. If more than one stream throws an exception, the later ones are added to the
        // first as suppressed exceptions. We don't catch Error on the grounds that it should be allowed
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 31 14:20:11 UTC 2024
    - 37.4K bytes
    - Viewed (0)
  10. src/cmd/asm/internal/asm/parse.go

    func (p *Parser) floatExpr() float64 {
    	tok := p.next()
    	switch tok.ScanToken {
    	case '(':
    		v := p.floatExpr()
    		if p.next().ScanToken != ')' {
    			p.errorf("missing closing paren")
    		}
    		return v
    	case '+':
    		return +p.floatExpr()
    	case '-':
    		return -p.floatExpr()
    	case scanner.Float:
    		return p.atof(tok.String())
    	}
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Sep 04 18:16:59 UTC 2024
    - 36.9K bytes
    - Viewed (0)
Back to top