mirror of
https://github.com/sbrow/zomq.git
synced 2026-08-26 10:53:32 -04:00
feat(zmq): Simplified bindings.
This commit is contained in:
@@ -31,7 +31,7 @@ main :: proc() {
|
||||
|
||||
req, cerr := zmq.socket(ctx, .REQ)
|
||||
if cerr != nil {
|
||||
log.panic(zmq.strerror(cerr))
|
||||
log.panicf("err: %v (%d) %s", cerr, cerr, zmq.strerror(cerr))
|
||||
}
|
||||
defer zmq.close(req)
|
||||
if err := zmq.connect(req, "inproc://echo"); err != nil {
|
||||
@@ -41,7 +41,7 @@ main :: proc() {
|
||||
echo(req, rep)
|
||||
}
|
||||
|
||||
echo :: proc(req, rep: zmq.Socket) {
|
||||
echo :: proc(client, server: zmq.Socket) {
|
||||
scanner: bufio.Scanner
|
||||
bufio.scanner_init(&scanner, os.to_reader(os.stdin))
|
||||
defer bufio.scanner_destroy(&scanner)
|
||||
@@ -52,20 +52,20 @@ echo :: proc(req, rep: zmq.Socket) {
|
||||
if len(line) == 0 {
|
||||
continue
|
||||
}
|
||||
if _, err := zmq.send(req, transmute([]u8)line); err != nil {
|
||||
if _, err := zmq.send(client, line); err != nil {
|
||||
fmt.eprintfln("send: %s", zmq.strerror(err))
|
||||
return
|
||||
}
|
||||
n, rerr := zmq.recv(rep, buf[:])
|
||||
n, rerr := zmq.recv(server, buf[:])
|
||||
if rerr != nil {
|
||||
fmt.eprintfln("rep recv: %s", zmq.strerror(rerr))
|
||||
return
|
||||
}
|
||||
if _, werr := zmq.send(rep, buf[:n]); werr != nil {
|
||||
fmt.eprintfln("rep send: %s", zmq.strerror(werr))
|
||||
if _, werr := zmq.send(server, buf[:n]); werr != nil {
|
||||
fmt.eprintfln("rep send: %v %s", werr, zmq.strerror(werr))
|
||||
return
|
||||
}
|
||||
m, qerr := zmq.recv(req, buf[:])
|
||||
m, qerr := zmq.recv(client, buf[:])
|
||||
if qerr != nil {
|
||||
fmt.eprintfln("req recv: %s", zmq.strerror(qerr))
|
||||
return
|
||||
|
||||
Reference in New Issue
Block a user