package rpc_parallel
Type-safe parallel library built on top of Async_rpc
Install
Dune Dependency
Authors
Maintainers
Sources
rpc_parallel-v0.16.0.tar.gz
sha256=1e6e85e9f7cf3c1c221ceaa8c0d7a2370d402ae2ee12d68aefb6ebe47ef33016
doc/src/rpc_parallel.krb/start_app.ml.html
Source file start_app.ml
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54
open! Core open! Async let backend = (module Backend : Rpc_parallel.Backend) let backend_and_settings krb_mode = Rpc_parallel.Backend_and_settings.T ((module Backend), krb_mode) ;; let start_app ?rpc_max_message_size ?rpc_handshake_timeout ?rpc_heartbeat_config ?when_parsing_succeeds ~krb_mode command = Rpc_parallel.start_app ?rpc_max_message_size ?rpc_handshake_timeout ?rpc_heartbeat_config ?when_parsing_succeeds (backend_and_settings krb_mode) command ;; module For_testing = struct let initialize here = Rpc_parallel.For_testing.initialize (backend_and_settings Mode.for_unit_test) here ;; end module Expert = struct let start_master_server_exn ?rpc_max_message_size ?rpc_handshake_timeout ?rpc_heartbeat_config ?pass_name ~krb_mode ~worker_command_args () = Rpc_parallel.Expert.start_master_server_exn ?rpc_max_message_size ?rpc_handshake_timeout ?rpc_heartbeat_config ?pass_name (backend_and_settings krb_mode) ~worker_command_args () ;; let worker_command = Rpc_parallel.Expert.worker_command backend end
sectionYPositions = computeSectionYPositions($el), 10)"
x-init="setTimeout(() => sectionYPositions = computeSectionYPositions($el), 10)"
>