Package: nanonext 1.5.1

Charlie Gao

nanonext: NNG (Nanomsg Next Gen) Lightweight Messaging Library

R binding for NNG (Nanomsg Next Gen), a successor to ZeroMQ. NNG is a socket library for reliable, high-performance messaging over in-process, IPC, TCP, WebSocket and secure TLS transports. Implements 'Scalability Protocols', a standard for common communications patterns including publish/subscribe, request/reply and service discovery. As its own threaded concurrency framework, provides a toolkit for asynchronous programming and distributed computing. Intuitive 'aio' objects resolve automatically when asynchronous operations complete, and synchronisation primitives allow R to wait upon events signalled by concurrent threads.

Authors:Charlie Gao [aut, cre], Hibiki AI Limited [cph], R Consortium [fnd]

nanonext_1.5.1.tar.gz
nanonext_1.5.1.zip(r-4.5)nanonext_1.5.1.zip(r-4.4)nanonext_1.5.1.zip(r-4.3)
nanonext_1.5.1.tgz(r-4.5-x86_64)nanonext_1.5.1.tgz(r-4.5-arm64)nanonext_1.5.1.tgz(r-4.4-x86_64)nanonext_1.5.1.tgz(r-4.4-arm64)nanonext_1.5.1.tgz(r-4.3-x86_64)nanonext_1.5.1.tgz(r-4.3-arm64)
nanonext_1.5.1.tar.gz(r-4.5-noble)nanonext_1.5.1.tar.gz(r-4.4-noble)
nanonext_1.5.1.tgz(r-4.4-emscripten)nanonext_1.5.1.tgz(r-4.3-emscripten)
nanonext.pdf |nanonext.html✨
nanonext/json (API)
NEWS

# Install 'nanonext' in R:
install.packages('nanonext', repos = c('https://test.r-universe.dev', 'https://cloud.r-project.org'))

Bug tracker:https://github.com/shikokuchuo/nanonext/issues

Pkgdown site:https://shikokuchuo.net

Uses libs:
  • mbedtls– Lightweight crypto and SSL/TLS library

On CRAN:

concurrencyhttpsipc-messagemessaging-librarynanomsgnngrpcsocket-communicationsynchronization-primitivestcp-protocolwebsocketmbedtls

9.83 score 59 stars 9 packages 32 scripts 5.7k downloads 64 exports 0 dependencies

Last updated 5 days agofrom:71b26067dd (on v1.5.1). Checks:11 OK. Indexed: no.

TargetResultLatest binary
Doc / VignettesOKFeb 16 2025
R-4.5-win-x86_64OKFeb 16 2025
R-4.5-mac-x86_64OKFeb 16 2025
R-4.5-mac-aarch64OKFeb 16 2025
R-4.5-linux-x86_64OKFeb 16 2025
R-4.4-win-x86_64OKFeb 16 2025
R-4.4-mac-x86_64OKFeb 16 2025
R-4.4-mac-aarch64OKFeb 16 2025
R-4.3-win-x86_64OKFeb 16 2025
R-4.3-mac-x86_64OKFeb 16 2025
R-4.3-mac-aarch64OKFeb 16 2025

Exports:.advance.context.interrupt.keep.mark.unresolved%~>%call_aiocall_aio_collect_aiocollect_aio_contextcvcv_resetcv_signalcv_valuedialis_aiois_error_valueis_nanois_ncurl_sessionis_nul_bytelistenlockmclockmessengermonitormsleepnanoncurlncurl_aioncurl_sessionnng_errornng_versionoptopt<-parse_urlpipe_notifyrandomread_monitorreaprecvrecv_aioreplyrequestsendsend_aioserial_configsocketstatstatus_codestop_aiostreamsubscribesurvey_timetls_configtransactunresolvedunsubscribeuntiluntil_waitwait_write_cert

Dependencies:

nanonext - NNG Lightweight Messaging Library

Rendered fromnanonext.Rmdusinglitedown::vignetteon Feb 16 2025.

Last update: 2025-01-27
Started: 2023-12-18

Readme and manuals

Help Manual

Help pageTopics
nanonext: NNG (Nanomsg Next Gen) Lightweight Messaging Librarynanonext-package nanonext
Technical Utility: Open Context.context
Signal Forwarder%~>%
Make ncurlAio Promiseas.promise.ncurlAio
Make recvAio Promiseas.promise.recvAio
Call the Value of an Asynchronous Aio Operationcall_aio call_aio_
Close Connectionclose close.nanoContext close.nanoDialer close.nanoListener close.nanoSocket close.nanoStream close.ncurlSession
Collect Data of an Aio or List of Aioscollect_aio collect_aio_
Open Contextcontext
Condition Variablescv cv_reset cv_signal cv_value until until_ wait wait_
Dial an Address from a Socketdial
Validatorsis_aio is_nano is_ncurl_session
Error Validatorsis_error_value is_nul_byte
Listen to an Address from a Socketlisten
Clock Utilitymclock
Messengermessenger
Monitor a Socket for Pipe Changesmonitor read_monitor
Sleep Utilitymsleep
Create Nano Objectnano
ncurlncurl
ncurl Asyncncurl_aio
ncurl Sessionncurl_session transact
Translate Error Codesnng_error
NNG Library Versionnng_version
Get and Set Options for a Socket, Context, Stream, Listener or Dialeropt opt<-
Parse URLparse_url
Pipe Notifypipe_notify
Protocols [Documentation]protocols
Random Data Generationrandom
Reapreap
Receiverecv
Receive Asyncrecv_aio
Reply over Context (RPC Server for Req/Rep Protocol)reply
Request over Context (RPC Client for Req/Rep Protocol)request
Sendsend
Send Asyncsend_aio
Create Serialization Configurationserial_config
Open Socketsocket
Start Listener/Dialerstart start.nanoDialer start.nanoListener
Get Statistic for a Socket, Listener or Dialerstat
Translate HTTP Status Codesstatus_code
Stop Asynchronous Aio Operationstop_aio
Open Streamstream
Subscribe / Unsubscribe Topicsubscribe unsubscribe
Set Survey Timesurvey_time
Create TLS Configurationtls_config
Transports [Documentation]transports
Query if an Aio is Unresolvedunresolved
Generate Self-Signed Certificate and Keywrite_cert