Skip to content

Commit c7b2976

Browse files
committed
make send/recv/send_aio/recv_aio functions generic
1 parent 428e550 commit c7b2976

32 files changed

+1137
-934
lines changed

DESCRIPTION

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
Package: nanonext
22
Type: Package
33
Title: NNG (Nanomsg Next Gen) Lightweight Messaging Library
4-
Version: 0.3.0.9000
4+
Version: 0.3.0.9001
55
Description: R binding for NNG (Nanomsg Next Gen), a successor to ZeroMQ. NNG is
66
a socket library providing high-performance scalability protocols,
77
implementing a cross-platform standard for messaging and communications.

NAMESPACE

Lines changed: 12 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,18 @@ S3method(print,nanoStream)
2424
S3method(print,recvAio)
2525
S3method(print,sendAio)
2626
S3method(print,unresolvedValue)
27+
S3method(recv,nanoContext)
28+
S3method(recv,nanoSocket)
29+
S3method(recv,nanoStream)
30+
S3method(recv_aio,nanoContext)
31+
S3method(recv_aio,nanoSocket)
32+
S3method(recv_aio,nanoStream)
33+
S3method(send,nanoContext)
34+
S3method(send,nanoSocket)
35+
S3method(send,nanoStream)
36+
S3method(send_aio,nanoContext)
37+
S3method(send_aio,nanoSocket)
38+
S3method(send_aio,nanoStream)
2739
S3method(setopt,nanoContext)
2840
S3method(setopt,nanoDialer)
2941
S3method(setopt,nanoListener)
@@ -53,10 +65,6 @@ export(setopt)
5365
export(socket)
5466
export(stop_aio)
5567
export(stream)
56-
export(stream_recv)
57-
export(stream_recv_aio)
58-
export(stream_send)
59-
export(stream_send_aio)
6068
export(subscribe)
6169
export(survey_time)
6270
export(unresolved)

NEWS.md

Lines changed: 8 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,14 @@
1-
# nanonext 0.3.0.9000 (development)
1+
# nanonext 0.3.0.9001 (development)
22

33
#### New Features
44

5-
* New 'stream' interface exposes low-level byte stream functionality in the NNG library. This is intended for communicating with non-NNG endpoints [currently experimental and subject to change].
6-
+ Functions include `stream()`, `stream_send()`, `stream_recv()`, `stream_send_aio()` and `stream_recv_aio()`.
5+
* New 'stream' interface exposes low-level byte stream functionality in the NNG library, intended for communicating with non-NNG endpoints, including but not limited to websocket servers.
6+
7+
#### Updates
8+
9+
* Unified synchronous `send()` and `recv()` functions, and their async counterparts `send_aio()` and `recv_aio()`, are now S3 generics and can be used across Sockets, Contexts as well as Streams.
10+
* A timeout can now be specified directly using the 'block' argument for synchronous sends over a Context/Stream.
11+
* `send_ctx()` and `recv_ctx()` are deprecated and will be removed in a future package version - the methods for `send()` and `recv()` should be used instead.
712

813
# nanonext 0.3.0
914

0 commit comments

Comments
 (0)