Skip to content

Commit 4eaa140

Browse files
committed
RC9b; further tidy-ups
1 parent ae8ba9f commit 4eaa140

File tree

2 files changed

+29
-29
lines changed

2 files changed

+29
-29
lines changed

README.md

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -365,7 +365,7 @@ aio
365365
#> < recvAio >
366366
#> - $data for message data
367367
aio$data |> str()
368-
#> num [1:100000000] -0.366 0.462 0.825 -1.21 -1.245 ...
368+
#> num [1:100000000] 1.5473 -1.808 0.0313 -0.8537 -2.4185 ...
369369
```
370370

371371
As `call_aio()` is blocking and will wait for completion, an alternative
@@ -526,11 +526,11 @@ ncurl("https://httpbin.org/headers")
526526
#> [1] 7b 0a 20 20 22 68 65 61 64 65 72 73 22 3a 20 7b 0a 20 20 20 20 22 48 6f 73
527527
#> [26] 74 22 3a 20 22 68 74 74 70 62 69 6e 2e 6f 72 67 22 2c 20 0a 20 20 20 20 22
528528
#> [51] 58 2d 41 6d 7a 6e 2d 54 72 61 63 65 2d 49 64 22 3a 20 22 52 6f 6f 74 3d 31
529-
#> [76] 2d 36 33 36 35 31 64 39 65 2d 37 64 34 65 62 31 34 32 35 35 63 62 36 30 66
530-
#> [101] 61 36 35 35 65 61 30 39 37 22 0a 20 20 7d 0a 7d 0a
529+
#> [76] 2d 36 33 36 35 34 63 38 31 2d 34 63 38 33 63 36 37 64 37 38 36 35 65 66 32
530+
#> [101] 35 32 61 65 38 61 35 38 30 22 0a 20 20 7d 0a 7d 0a
531531
#>
532532
#> $data
533-
#> [1] "{\n \"headers\": {\n \"Host\": \"httpbin.org\", \n \"X-Amzn-Trace-Id\": \"Root=1-63651d9e-7d4eb14255cb60fa655ea097\"\n }\n}\n"
533+
#> [1] "{\n \"headers\": {\n \"Host\": \"httpbin.org\", \n \"X-Amzn-Trace-Id\": \"Root=1-63654c81-4c83c67d7865ef252ae8a580\"\n }\n}\n"
534534
```
535535

536536
For advanced use, supports additional HTTP methods such as POST or PUT.
@@ -551,13 +551,13 @@ res
551551

552552
call_aio(res)$headers
553553
#> $Date
554-
#> [1] "Fri, 04 Nov 2022 14:11:42 GMT"
554+
#> [1] "Fri, 04 Nov 2022 17:31:45 GMT"
555555
#>
556556
#> $Server
557557
#> [1] "gunicorn/19.9.0"
558558

559559
res$data
560-
#> [1] "{\n \"args\": {}, \n \"data\": \"{\\\"key\\\": \\\"value\\\"}\", \n \"files\": {}, \n \"form\": {}, \n \"headers\": {\n \"Authorization\": \"Bearer APIKEY\", \n \"Content-Length\": \"16\", \n \"Content-Type\": \"application/json\", \n \"Host\": \"httpbin.org\", \n \"X-Amzn-Trace-Id\": \"Root=1-63651d9e-37efe928438712bb5a2245d6\"\n }, \n \"json\": {\n \"key\": \"value\"\n }, \n \"origin\": \"213.86.169.34\", \n \"url\": \"http://httpbin.org/post\"\n}\n"
560+
#> [1] "{\n \"args\": {}, \n \"data\": \"{\\\"key\\\": \\\"value\\\"}\", \n \"files\": {}, \n \"form\": {}, \n \"headers\": {\n \"Authorization\": \"Bearer APIKEY\", \n \"Content-Length\": \"16\", \n \"Content-Type\": \"application/json\", \n \"Host\": \"httpbin.org\", \n \"X-Amzn-Trace-Id\": \"Root=1-63654c81-75d995a77f18b2cf33ed5448\"\n }, \n \"json\": {\n \"key\": \"value\"\n }, \n \"origin\": \"213.86.169.34\", \n \"url\": \"http://httpbin.org/post\"\n}\n"
561561
```
562562

563563
In this respect, it may be used as a performant and lightweight method
@@ -599,10 +599,10 @@ s |> send('{"action": "subscribe", "symbols": "EURUSD"}')
599599
#> [1] 0
600600

601601
s |> recv()
602-
#> [1] "{\"s\":\"EURUSD\",\"a\":0.98913,\"b\":0.98911,\"dc\":\"1.4366\",\"dd\":\"0.0142\",\"ppms\":false,\"t\":1667571103000}"
602+
#> [1] "{\"s\":\"EURUSD\",\"a\":0.99199,\"b\":0.99192,\"dc\":\"1.7208\",\"dd\":\"0.0171\",\"ppms\":false,\"t\":1667583106000}"
603603

604604
s |> recv()
605-
#> [1] "{\"s\":\"EURUSD\",\"a\":0.98913,\"b\":0.9891,\"dc\":\"1.4366\",\"dd\":\"0.0142\",\"ppms\":false,\"t\":1667571103000}"
605+
#> [1] "{\"s\":\"EURUSD\",\"a\":0.99198,\"b\":0.99196,\"dd\":\"0.0171\",\"dc\":\"1.7198\",\"ppms\":false,\"t\":1667583106000}"
606606

607607
close(s)
608608
```

src/aio.c

Lines changed: 21 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -750,27 +750,27 @@ SEXP rnng_ncurl_aio(SEXP http, SEXP convert, SEXP method, SEXP headers, SEXP dat
750750
#endif
751751
Rf_defineVar(nano_AioSymbol, aio, env);
752752

753-
SEXP sfun, hfun, rfun, dfun;
754-
PROTECT(sfun = Rf_allocSExp(CLOSXP));
755-
SET_FORMALS(sfun, nano_aioFormals);
756-
SET_BODY(sfun, CAR(nano_aioNFuncs));
757-
SET_CLOENV(sfun, clo);
758-
R_MakeActiveBinding(nano_StatusSymbol, sfun, env);
759-
PROTECT(hfun = Rf_allocSExp(CLOSXP));
760-
SET_FORMALS(hfun, nano_aioFormals);
761-
SET_BODY(hfun, CADR(nano_aioNFuncs));
762-
SET_CLOENV(hfun, clo);
763-
R_MakeActiveBinding(nano_HeadersSymbol, hfun, env);
764-
PROTECT(rfun = Rf_allocSExp(CLOSXP));
765-
SET_FORMALS(rfun, nano_aioFormals);
766-
SET_BODY(rfun, CADDR(nano_aioNFuncs));
767-
SET_CLOENV(rfun, clo);
768-
R_MakeActiveBinding(nano_RawSymbol, rfun, env);
769-
PROTECT(dfun = Rf_allocSExp(CLOSXP));
770-
SET_FORMALS(dfun, nano_aioFormals);
771-
SET_BODY(dfun, CADDDR(nano_aioNFuncs));
772-
SET_CLOENV(dfun, clo);
773-
R_MakeActiveBinding(nano_DataSymbol, dfun, env);
753+
SEXP fun;
754+
PROTECT(fun = Rf_allocSExp(CLOSXP));
755+
SET_FORMALS(fun, nano_aioFormals);
756+
SET_BODY(fun, CAR(nano_aioNFuncs));
757+
SET_CLOENV(fun, clo);
758+
R_MakeActiveBinding(nano_StatusSymbol, fun, env);
759+
PROTECT(fun = Rf_allocSExp(CLOSXP));
760+
SET_FORMALS(fun, nano_aioFormals);
761+
SET_BODY(fun, CADR(nano_aioNFuncs));
762+
SET_CLOENV(fun, clo);
763+
R_MakeActiveBinding(nano_HeadersSymbol, fun, env);
764+
PROTECT(fun = Rf_allocSExp(CLOSXP));
765+
SET_FORMALS(fun, nano_aioFormals);
766+
SET_BODY(fun, CADDR(nano_aioNFuncs));
767+
SET_CLOENV(fun, clo);
768+
R_MakeActiveBinding(nano_RawSymbol, fun, env);
769+
PROTECT(fun = Rf_allocSExp(CLOSXP));
770+
SET_FORMALS(fun, nano_aioFormals);
771+
SET_BODY(fun, CADDDR(nano_aioNFuncs));
772+
SET_CLOENV(fun, clo);
773+
R_MakeActiveBinding(nano_DataSymbol, fun, env);
774774

775775
Rf_classgets(env, nano_ncurlAio);
776776

0 commit comments

Comments
 (0)