Package: rho.async 0.0.1.9000
rho.async: Rho Async Task and Stream Contracts
Defines S7 task, stream, cancellation, and composition contracts for asynchronous R interfaces. Adapters connect nanonext asynchronous handles and promises while keeping every blocking wait explicit.
Authors:
rho.async_0.0.1.9000.tar.gz
rho.async_0.0.1.9000.zip(r-4.7)rho.async_0.0.1.9000.zip(r-4.6)rho.async_0.0.1.9000.zip(r-4.5)
rho.async_0.0.1.9000.tgz(r-4.6-any)rho.async_0.0.1.9000.tgz(r-4.5-any)
rho.async_0.0.1.9000.tar.gz(r-4.7-any)rho.async_0.0.1.9000.tar.gz(r-4.6-any)
rho.async_0.0.1.9000.tgz(r-4.6-emscripten)
manual.pdf |manual.html✨
DESCRIPTION |NEWS
card.svg |card.png
rho.async/json (API)
| # Install 'rho.async' in R: |
| install.packages('rho.async', repos = c('https://sounkou-bioinfo.r-universe.dev', 'https://cloud.r-project.org')) |
Bug tracker:https://github.com/sounkou-bioinfo/rho/issues
Last updated from:b0668a1173. Checks:8 OK, 1 ERROR. Indexed: yes.
| Target | Result | Time | Files | Syslog |
|---|---|---|---|---|
| linux-devel-x86_64 | OK | 155 | ||
| source / vignettes | ERROR | 156 | ||
| linux-release-x86_64 | OK | 142 | ||
| macos-release-arm64 | OK | 115 | ||
| macos-oldrel-arm64 | OK | 94 | ||
| windows-devel | OK | 77 | ||
| windows-release | OK | 89 | ||
| windows-oldrel | OK | 63 | ||
| wasm-release | OK | 103 |
Exports:rho_allrho_as_promiserho_as_taskrho_awaitrho_cancelrho_catchrho_contract_violationrho_coro_taskrho_enqueuerho_is_streamrho_is_taskrho_later_event_pumprho_list_streamrho_new_staterho_pendingrho_pollrho_poll_completerho_poll_failedrho_poll_pendingrho_pump_eventsrho_racerho_register_task_callbackrho_rejectedrho_remove_task_callbackrho_serial_queuerho_signal_contract_violationrho_stream_closerho_stream_collectrho_stream_endrho_stream_flat_maprho_stream_from_taskrho_stream_maprho_stream_nextrho_stream_valuerho_taskrho_task_callback_bridgerho_task_from_functionrho_task_from_promiserho_thenrho_timeoutrho_wrap_aioRhoAsyncErrorRhoAwaitableRhoCancellationRhoEventPumpRhoEventPumpErrorRhoEventPumpIdleRhoEventPumpProgressRhoEventPumpResultRhoEventPumpUnsupportedRhoFlatMappedStreamRhoFunctionTaskRhoImmediateTaskRhoLaterEventPumpRhoListStreamRhoMappedStreamRhoNanonextAioTaskRhoPollCompleteRhoPollDecisionRhoPollFailedRhoPollPendingRhoPromiseTaskRhoRejectedTaskRhoSerialQueueRhoStreamRhoStreamEndRhoStreamItemRhoStreamLikeRhoStreamValueRhoTaskRhoTaskCallbackBridgeRhoTaskCallbackErrorRhoTaskCallbackNameInUseRhoTaskCallbackRegistrationErrorRhoTaskCallbackRemovalErrorRhoTaskQueueRhoTaskStreamRhoTimeoutError
Dependencies:clicorofastmaplaterlifecyclemagrittrnanonextotelpromisesR6RcpprlangS7s7contract
Readme and manuals
Help Manual
| Help page | Topics |
|---|---|
| Asynchronous task and stream contracts | RhoAsyncError RhoAwaitable RhoCancellation RhoEventPump RhoEventPumpError RhoEventPumpIdle RhoEventPumpProgress RhoEventPumpResult RhoEventPumpUnsupported RhoFlatMappedStream RhoFunctionTask RhoImmediateTask RhoLaterEventPump RhoListStream RhoMappedStream RhoNanonextAioTask RhoPollComplete RhoPollDecision RhoPollFailed RhoPollPending RhoPromiseTask RhoRejectedTask RhoSerialQueue RhoStream RhoStreamEnd RhoStreamItem RhoStreamLike RhoStreamValue RhoTask RhoTaskCallbackBridge RhoTaskCallbackError RhoTaskCallbackNameInUse RhoTaskCallbackRegistrationError RhoTaskCallbackRemovalError RhoTaskQueue RhoTaskStream RhoTimeoutError rho_all rho_async_contracts rho_as_promise rho_as_task rho_await rho_cancel rho_catch rho_contract_violation rho_coro_task rho_enqueue rho_is_stream rho_is_task rho_later_event_pump rho_list_stream rho_new_state rho_pending rho_poll rho_poll_complete rho_poll_failed rho_poll_pending rho_pump_events rho_race rho_register_task_callback rho_rejected rho_remove_task_callback rho_serial_queue rho_signal_contract_violation rho_stream_close rho_stream_collect rho_stream_end rho_stream_flat_map rho_stream_from_task rho_stream_map rho_stream_next rho_stream_value rho_task rho_task_callback_bridge rho_task_from_function rho_task_from_promise rho_then rho_timeout rho_wrap_aio |
