- Sort Score
- Num 10 results
- Language All
Results 281 - 290 of 506 for convey (0.1 seconds)
-
tests/test_dependency_yield_scope_websockets.py
): @app.websocket("/broken-scope") async def get_broken( websocket: WebSocket, sessions: BrokenSessionsDep ) -> Any: # pragma: no cover pass def test_named_function_scope() -> None: global_context.set({}) global_state = global_context.get() with client.websocket_connect("/named-function-scope") as websocket:Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Wed Dec 17 21:25:59 GMT 2025 - 6K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/group/ApiAdminGroupAction.java
} /** * Creates an edit body from a group entity for API responses. * * @param entity the group entity to convert * @return edit body containing the entity data */ protected EditBody createEditBody(final Group entity) { final EditBody body = new EditBody(); copyBeanToBean(entity, body, copyOp -> {Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Thu Aug 07 03:06:29 GMT 2025 - 8K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/boostdoc/ApiAdminBoostdocAction.java
} /** * Creates an EditBody from a BoostDocumentRule entity for API responses. * * @param entity the BoostDocumentRule entity to convert * @return the converted EditBody object */ protected EditBody createEditBody(final BoostDocumentRule entity) { final EditBody form = new EditBody();Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Thu Aug 07 03:06:29 GMT 2025 - 7.9K bytes - Click Count (0) -
cmd/listen-notification-handlers.go
mergeCh := make(chan []byte, globalAPIConfig.getRequestsPoolCapacity()*len(globalEndpoints.Hostnames())) localCh := make(chan event.Event, globalAPIConfig.getRequestsPoolCapacity()) // Convert local messages to JSON and send to mergeCh go func() { buf := bytes.NewBuffer(grid.GetByteBuffer()[:0]) enc := json.NewEncoder(buf) tmpEvt := struct{ Records []event.Event }{[]event.Event{{}}} for {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 6K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/webconfig/ApiAdminWebconfigAction.java
}); return asJson(new ApiResponse().status(Status.OK).result()); } /** * Creates an EditBody from a WebConfig entity. * * @param entity the web configuration entity to convert * @return the converted EditBody */ protected EditBody createEditBody(final WebConfig entity) { final EditBody body = new EditBody(); copyBeanToBean(entity, body, copyOp -> {Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Thu Aug 07 03:06:29 GMT 2025 - 8.8K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/labeltype/ApiAdminLabeltypeAction.java
}); return asJson(new ApiResponse().status(Status.OK).result()); } /** * Creates an EditBody from a LabelType entity. * * @param entity the label type entity to convert * @return the converted EditBody */ protected EditBody createEditBody(final LabelType entity) { final EditBody body = new EditBody(); copyBeanToBean(entity, body, copyOp -> {Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Thu Aug 07 03:06:29 GMT 2025 - 8.5K bytes - Click Count (0) -
guava/src/com/google/common/net/InetAddresses.java
int hextet = 0; for (int i = start; i < end; i++) { hextet = hextet << 4; hextet |= Character.digit(ipString.charAt(i), 16); } return (short) hextet; } /** * Convert a byte array into an InetAddress. * * <p>{@link InetAddress#getByAddress} is documented as throwing a checked exception "if IP * address is of illegal length." We replace it with an unchecked exception, for use by callersCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Wed Feb 19 21:24:11 GMT 2025 - 47.4K bytes - Click Count (0) -
src/test/java/jcifs/smb1/dcerpc/ndr/NdrShortTest.java
import org.junit.jupiter.params.ParameterizedTest; import org.junit.jupiter.params.provider.ValueSource; import org.mockito.junit.jupiter.MockitoExtension; /** * Unit tests for {@link NdrShort}. The tests cover construction, * encoding and decoding logic, masking behaviour, alignment handling and * interaction with {@link NdrBuffer}. All public behaviour is exercised. */ @ExtendWith(MockitoExtension.class) class NdrShortTest {Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 5.1K bytes - Click Count (0) -
configure.py
except subprocess.CalledProcessError as e: output = e.output else: output = subprocess.check_output(cmd, stderr=stderr) return output.decode('UTF-8').strip() def cygpath(path): """Convert path from posix to windows.""" return os.path.abspath(path).replace('\\', '/') def get_python_path(environ_cp, python_bin_path): """Get the python site package paths.""" python_paths = []Created: Tue Dec 30 12:39:10 GMT 2025 - Last Modified: Wed Apr 30 15:18:54 GMT 2025 - 48.3K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/fileconfig/ApiAdminFileconfigAction.java
* Creates an edit body from a file configuration entity for API responses. * Processes permissions and virtual hosts for proper display formatting. * * @param entity the file configuration entity to convert * @return edit body containing the entity data */ protected EditBody createEditBody(final FileConfig entity) { final EditBody body = new EditBody(); copyBeanToBean(entity, body, copyOp -> {Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Thu Aug 07 03:06:29 GMT 2025 - 9.2K bytes - Click Count (0)