Search Options

Results per page
Sort
Preferred Languages
Advance

Results 181 - 190 of 982 for Close (0.57 sec)

  1. src/main/java/org/codelibs/fess/suggest/index/contents/querylog/QueryLogReader.java

     * It extends the {@code Closeable} interface, ensuring that resources can be released when no longer needed.
     */
    public interface QueryLogReader extends Closeable {
        /**
         * Reads a query log.
         * @return The query log.
         */
        QueryLog read();
    
        @Override
        void close();
    Registered: Sat Dec 20 13:04:59 UTC 2025
    - Last Modified: Fri Jul 04 14:00:23 UTC 2025
    - 1.1K bytes
    - Viewed (0)
  2. src/main/java/jcifs/dcerpc/DcerpcPipeHandle.java

                }
                off += r;
            }
            return off;
        }
    
        @Override
        public void close() throws IOException {
            super.close();
            try {
                this.handle.close();
            } finally {
                this.pipe.close();
            }
        }
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 5.6K bytes
    - Viewed (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/WebSocketWriter.kt

            messageBuffer.readAndWriteUnsafe(maskCursor!!)
            maskCursor.seek(0L)
            toggleMask(maskCursor, maskKey)
            maskCursor.close()
          }
        }
    
        sinkBuffer.write(messageBuffer, dataSize)
        sink.flush()
      }
    
      override fun close() {
        messageDeflater?.closeQuietly()
        sink.closeQuietly()
      }
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 6K bytes
    - Viewed (0)
  4. internal/store/batch.go

    	default:
    	}
    	if _, err := b.store.PutMultiple(b.items); err != nil {
    		return err
    	}
    	b.items = make([]I, 0, b.limit)
    	return nil
    }
    
    // Close commits the pending items and quits the goroutines
    func (b *Batch[I]) Close() error {
    	defer func() {
    		close(b.quitCh)
    	}()
    
    	b.Lock()
    	defer b.Unlock()
    	return b.commit()
    }
    
    // NewBatch creates a new batch
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  5. build-logic/documentation/src/main/groovy/gradlebuild/docs/model/SimpleClassMetaDataRepository.java

                    ObjectOutputStream objOutputStream = new ObjectOutputStream(new BufferedOutputStream(outputStream));
                    objOutputStream.writeObject(classes);
                    objOutputStream.close();
                } finally {
                    outputStream.close();
                }
            } catch (IOException e) {
                throw new GradleException(String.format("Could not write meta-data to %s.", repoFile), e);
            }
        }
    
    Registered: Wed Dec 31 11:36:14 UTC 2025
    - Last Modified: Wed May 21 06:20:45 UTC 2025
    - 4K bytes
    - Viewed (0)
  6. internal/stmt_store/stmt_store.go

    	*sql.Stmt
    	Transaction bool
    	prepared    chan struct{}
    	prepareErr  error
    }
    
    func (stmt *Stmt) Error() error {
    	return stmt.prepareErr
    }
    
    func (stmt *Stmt) Close() error {
    	<-stmt.prepared
    
    	if stmt.Stmt != nil {
    		return stmt.Stmt.Close()
    	}
    	return nil
    }
    
    // Store defines an interface for managing the caching operations of SQL statements (Stmt).
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Sun Apr 27 06:05:16 UTC 2025
    - 6K bytes
    - Viewed (0)
  7. okhttp/src/jvmTest/kotlin/okhttp3/AutobahnTester.kt

            ) {
              webSocket.send(text)
            }
    
            override fun onClosing(
              webSocket: WebSocket,
              code: Int,
              reason: String,
            ) {
              webSocket.close(1000, null)
              latch.countDown()
            }
    
            override fun onFailure(
              webSocket: WebSocket,
              t: Throwable,
              response: Response?,
            ) {
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 4.6K bytes
    - Viewed (0)
  8. .teamcity/.mvn/wrapper/MavenWrapperDownloader.java

            rbc = Channels.newChannel(website.openStream());
            FileOutputStream fos = new FileOutputStream(destination);
            fos.getChannel().transferFrom(rbc, 0, Long.MAX_VALUE);
            fos.close();
            rbc.close();
        }
    
    Registered: Wed Dec 31 11:36:14 UTC 2025
    - Last Modified: Wed Feb 26 01:48:39 UTC 2020
    - 4.8K bytes
    - Viewed (0)
  9. api/go1.8.txt

    pkg database/sql/driver, type RowsColumnTypeDatabaseTypeName interface { Close, ColumnTypeDatabaseTypeName, Columns, Next }
    pkg database/sql/driver, type RowsColumnTypeDatabaseTypeName interface, Close() error
    pkg database/sql/driver, type RowsColumnTypeDatabaseTypeName interface, Columns() []string
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Wed Dec 21 05:25:57 UTC 2016
    - 16.3K bytes
    - Viewed (0)
  10. scripts/playwright/separate_openapi_schemas/image05.py

        # Manually add the screenshot
        page.screenshot(
            path="docs/en/docs/img/tutorial/separate-openapi-schemas/image05.png"
        )
    
        # ---------------------
        context.close()
        browser.close()
    
    
    process = subprocess.Popen(
        ["uvicorn", "docs_src.separate_openapi_schemas.tutorial002:app"]
    )
    try:
        with sync_playwright() as playwright:
            run(playwright)
    finally:
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Fri Sep 13 09:14:46 UTC 2024
    - 984 bytes
    - Viewed (0)
Back to top