Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 91 - 100 of 213 for sendMsg (0.07 seconds)

  1. internal/event/target/redis.go

    		return err
    	}
    	if err := target.init(); err != nil {
    		return err
    	}
    	_, err := target.isActive()
    	if err != nil {
    		return err
    	}
    	return target.send(eventData)
    }
    
    // send - sends an event to the redis.
    func (target *RedisTarget) send(eventData event.Event) error {
    	conn := target.pool.Get()
    	defer conn.Close()
    
    	if target.args.Format == event.NamespaceFormat {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 9.1K bytes
    - Click Count (0)
  2. src/main/java/org/codelibs/fess/util/ThreadDumpUtil.java

                    }
                });
            } catch (final Exception e) {
                logger.warn("Failed to write thread dump: file={}", file, e);
            }
        }
    
        /**
         * Processes all thread information and sends it to the provided consumer.
         *
         * @param writer the consumer that will handle each line of thread dump output
         */
        public static void processThreadDump(final Consumer<String> writer) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 3.3K bytes
    - Click Count (0)
  3. docs/en/docs/tutorial/response-model.md

    Now, whenever a browser is creating a user with a password, the API will return the same password in the response.
    
    In this case, it might not be a problem, because it's the same user sending the password.
    
    But if we use the same model for another *path operation*, we could be sending our user's passwords to every client.
    
    /// danger
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 05 18:13:19 GMT 2026
    - 15.5K bytes
    - Click Count (0)
  4. docs/de/llm-prompt.md

    * the performance: NOT die Performance
    * the query: die Query
    * the recap: die Zusammenfassung
    * the request (what the client sends to the server): der Request
    * the request body: der Requestbody
    * the request bodies (plural): die Requestbodys
    * the response (what the server sends back to the client): die Response
    * the return type: der Rückgabetyp
    * the return value: der Rückgabewert
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Mon Dec 29 18:54:20 GMT 2025
    - 9.8K bytes
    - Click Count (0)
  5. docs/en/docs/tutorial/request-forms.md

    ///
    
    ## About "Form Fields" { #about-form-fields }
    
    The way HTML forms (`<form></form>`) sends the data to the server normally uses a "special" encoding for that data, it's different from JSON.
    
    **FastAPI** will make sure to read that data from the right place instead of JSON.
    
    /// note | Technical Details
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 05 18:13:19 GMT 2026
    - 2.6K bytes
    - Click Count (0)
  6. internal/deadlineconn/deadlineconn.go

    	defer c.mu.Unlock()
    	c.abortWrites.Store(!t.IsZero() && time.Until(t) < 0)
    	c.infWrites.Store(t.IsZero())
    	c.writeSetAt = time.Time{}
    	return c.Conn.SetWriteDeadline(t)
    }
    
    // Close wraps conn.Close and stops sending deadline updates.
    func (c *DeadlineConn) Close() error {
    	c.abortReads.Store(true)
    	c.abortWrites.Store(true)
    	return c.Conn.Close()
    }
    
    // WithReadDeadline sets a new read side net.Conn deadline.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Dec 02 13:21:17 GMT 2024
    - 5.1K bytes
    - Click Count (0)
  7. src/main/java/jcifs/internal/smb2/multichannel/ChannelManager.java

                    );
            request.setMaxOutputResponse(65536);
            request.setFlags(Smb2IoctlRequest.SMB2_O_IOCTL_IS_FSCTL);
    
            // Note: This IOCTL must be sent on an existing session
            // The actual sending would need integration with the session's transport
            // For now, we're preparing the request structure correctly
    
            // TODO: Integration point - send request through session.send()
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 21 11:13:46 GMT 2025
    - 20K bytes
    - Click Count (0)
  8. src/test/java/jcifs/internal/witness/WitnessIntegrationTest.java

            // Test duplicate unregistration
            assertFalse(mockService.unregisterWitness(regId));
        }
    
        @Test
        void testMockServiceNotifications() {
            // Test notification sending (just logs for mock)
            mockService.sendNotification(WitnessEventType.RESOURCE_CHANGE, "TestResource");
    
            // Register a witness first
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 23 09:06:40 GMT 2025
    - 9.8K bytes
    - Click Count (0)
  9. src/test/java/jcifs/smb/SmbFileHandleImplTest.java

            SmbException ex2 = assertThrows(SmbException.class, h::getFileId);
            assertEquals("Descriptor is no longer valid", ex2.getMessage());
        }
    
        @Test
        @DisplayName("close(long) sends SMB2 close request and releases tree when SMB2")
        void close_withLastWrite_smb2_sendsCloseAndReleases() throws CIFSException {
            when(cfg.isTraceResourceUsage()).thenReturn(false);
            stubValidTree(5L, true, true);
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 12.3K bytes
    - Click Count (0)
  10. docs/en/docs/tutorial/testing.md

    ///
    
    /// tip
    
    If you want to call `async` functions in your tests apart from sending requests to your FastAPI application (e.g. asynchronous database functions), have a look at the [Async Tests](../advanced/async-tests.md) in the advanced tutorial.
    
    ///
    
    ## Separating tests { #separating-tests }
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 05 18:13:19 GMT 2026
    - 5.7K bytes
    - Click Count (0)
Back to Top