- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 77 for Sing (0.02 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
src/test/java/org/codelibs/fess/suggest/SuggesterTest.java
String field = settings.array().get(SuggestSettings.DefaultKeys.SUPPORTED_FIELDS)[0]; Map<String, Object> document = new HashMap<>(); document.put(field, "Sing the Supercalifragilisticexpialidocious for Honorificabilitudinitatibus"); suggester.indexer().indexFromDocument(new Map[] { document }); suggester.refresh();
Created: Fri Apr 17 09:08:13 GMT 2026 - Last Modified: Sun Feb 01 12:48:24 GMT 2026 - 37.1K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt
peer.sendFrame().ping(false, 2, 3) peer.acceptFrame() // PING peer.play() // Play it back. connect(peer) // Verify the peer received what was expected. val ping = peer.takeFrame() assertThat(ping.type).isEqualTo(Http2.TYPE_PING) assertThat(ping.streamId).isEqualTo(0) assertThat(ping.payload1).isEqualTo(2) assertThat(ping.payload2).isEqualTo(3)
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Thu Jul 31 04:18:40 GMT 2025 - 75.5K bytes - Click Count (0) -
cmd/consolelogger.go
console *console.Target nodeName string logBuf *ring.Ring } // NewConsoleLogger - creates new HTTPConsoleLoggerSys with all nodes subscribed to // the console logging pub sub system func NewConsoleLogger(ctx context.Context, w io.Writer) *HTTPConsoleLoggerSys { return &HTTPConsoleLoggerSys{ pubsub: pubsub.New[log.Info, madmin.LogMask](8), console: console.New(w), logBuf: ring.New(defaultLogBufferCount), } }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 5.4K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/job/PingSearchEngineJobTest.java
assertEquals("Status of production-cluster is changed to GREEN.", result); } // Test with exception during ping @Test public void test_execute_pingException() { SearchEngineClient searchEngineClient = new SearchEngineClient() { @Override public PingResponse ping() { throw new RuntimeException("Connection failed"); } };
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 18.9K bytes - Click Count (0) -
internal/s3select/jstream/decoder_test.go
var ( counter int mv *MetaValue body = `{ "bio": "bada bing bada boom", "id": 1, "name": "Charles" } { "bio": "bada bing bada boom", "id": 2, "name": "Charles" } { "bio": "bada bing bada boom", "id": 3, "name": "Charles" } { "bio": "bada bing bada boom", "id": 4, "name": "Charles" } { "bio": "bada bing bada boom", "id": 5, "name": "Charles" } ` ) decoder := NewDecoder(mkReader(body), 0)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 6.6K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/RealWebSocketTest.kt
taskFaker.advanceUntil(ns(500L)) server.processNextFrame() // Ping. client.processNextFrame() // Pong. taskFaker.advanceUntil(ns(1000L)) server.processNextFrame() // Ping. client.processNextFrame() // Pong. taskFaker.advanceUntil(ns(1500L)) server.processNextFrame() // Ping. client.processNextFrame() // Pong. } @Test
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Thu Jul 31 04:18:40 GMT 2025 - 18.7K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketRecorder.kt
} fun assertBinaryMessage(payload: ByteString?) { assertThat(nextEvent()).isEqualTo(Message(payload)) } fun assertPing(payload: ByteString) { assertThat(nextEvent()).isEqualTo(Ping(payload)) } fun assertPong(payload: ByteString) { assertThat(nextEvent()).isEqualTo(Pong(payload)) } fun assertClosing( code: Int, reason: String, ) {
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Feb 03 22:17:59 GMT 2026 - 6.8K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt
payload2: Int, ) { try { writer.ping(reply, payload1, payload2) } catch (e: IOException) { failConnection(e) } } /** For testing: sends a ping and waits for a pong. */ @Throws(InterruptedException::class) fun writePingAndAwaitPong() { writePing() awaitPong() } /** For testing: sends a ping to be awaited with [awaitPong]. */Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 31.9K bytes - Click Count (0) -
tests/test_sse.py
] assert len(data_lines) == 2 # Keepalive ping tests keepalive_app = FastAPI() @keepalive_app.get("/slow-async", response_class=EventSourceResponse) async def slow_async_stream(): yield {"n": 1} # Sleep longer than the (monkeypatched) ping interval so a keepalive # comment is emitted before the next item. await asyncio.sleep(0.3)Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Sun Mar 01 09:21:52 GMT 2026 - 9.8K bytes - Click Count (0) -
prepare_stmt.go
if err == nil { return stmt.QueryRowContext(ctx, args...) } return &sql.Row{} } func (db *PreparedStmtDB) Ping() error { conn, err := db.GetDBConn() if err != nil { return err } return conn.Ping() } type PreparedStmtTX struct { Tx PreparedStmtDB *PreparedStmtDB } func (db *PreparedStmtTX) GetDBConn() (*sql.DB, error) {Created: Sun Apr 05 09:35:12 GMT 2026 - Last Modified: Fri Apr 25 08:22:26 GMT 2025 - 5.7K bytes - Click Count (0)