Skip to contents
nanonext nanonext-package
nanonext: NNG (Nanomsg Next Gen) Lightweight Messaging Library
as.promise(<ncurlAio>)
Make ncurlAio Promise
as.promise(<recvAio>)
Make recvAio Promise
call_aio() call_aio_()
Call the Value of an Asynchronous Aio Operation
close(<nanoContext>) close(<nanoDialer>) close(<nanoListener>) close(<ncurlSession>) close(<nanoSocket>) close(<nanoPipe>) close(<nanoStream>)
Close Connection
collect_aio() collect_aio_()
Collect Data of an Aio or List of Aios
collect_pipe()
Collect the Pipe from an Aio
context()
Open Context
cv() wait() wait_() until() until_() cv_value() cv_reset() cv_signal()
Condition Variables
dial()
Dial an Address from a Socket
.context()
Technical Utility: Open Context
`%~>%`
Signal Forwarder
is_aio() is_nano() is_ncurl_session()
Validators
is_error_value() is_nul_byte()
Error Validators
listen()
Listen to an Address from a Socket
lock() unlock()
Lock / Unlock a Socket
mclock()
Clock Utility
messenger()
Messenger
msleep()
Sleep Utility
nano()
Create Nano Object
ncurl()
ncurl
ncurl_aio()
ncurl Async
ncurl_session() transact()
ncurl Session
nng_error()
Translate Error Codes
nng_version()
NNG Library Version
opt() `opt<-`()
Get and Set Options for a Socket, Context, Stream, Listener or Dialer
parse_url()
Parse URL
pipe_notify()
Pipe Notify
protocols
Protocols [Documentation]
random()
Random Data Generation
reap()
Reap
recv()
Receive
recv_aio()
Receive Async
reply()
Reply over Context (RPC Server for Req/Rep Protocol)
request()
Request over Context (RPC Client for Req/Rep Protocol)
send()
Send
send_aio()
Send Async
serial_config()
Create Serialization Configuration
socket()
Open Socket
start(<nanoListener>) start(<nanoDialer>)
Start Listener/Dialer
stat()
Get Statistic for a Socket, Listener or Dialer
status_code()
Translate HTTP Status Codes
stop_aio()
Stop Asynchronous Aio Operation
stream()
Open Stream
subscribe() unsubscribe()
Subscribe / Unsubscribe Topic
survey_time()
Set Survey Time
tls_config()
Create TLS Configuration
transports
Transports [Documentation]
unresolved()
Query if an Aio is Unresolved
write_cert()
Generate Self-Signed Certificate and Key