Skip to content

Commit eab240c

Browse files
EDBCREPOEDBCREPO
committed
📌 Nodepp | Bug Fixing | V1.3.1 📌
1 parent 2f39a65 commit eab240c

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

65 files changed

+1375
-822
lines changed

‎examples/35-WS-Client.cpp‎

Lines changed: 3 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -8,26 +8,20 @@ using namespace nodepp;
88
void onMain() {
99

1010
auto client = ws::client( "ws://localhost:8000/" );
11-
auto cin = fs::std_input();
1211

1312
client.onConnect([=]( ws_t cli ){
1413

1514
console::log("connected", cli.get_peername() );
1615

17-
cli.onData([]( string_t chunk ){
18-
console::log("client:>",chunk);
16+
cli.onData([]( string_t data ){
17+
console::log( data );
1918
});
2019

21-
cin.onData([=]( string_t data ){
22-
cli.write( data );
23-
});
24-
2520
cli.onDrain([=](){
2621
console::log("closed");
27-
cin.close();
2822
});
2923

30-
stream::pipe( cin );
24+
stream::pipe( cli );
3125

3226
});
3327

‎examples/36-WS-Server.cpp‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -32,6 +32,8 @@ void onMain(){
3232
console::log("closed");
3333
});
3434

35+
stream::pipe( cli );
36+
3537
});
3638

3739
server.listen( "localhost", 8000, [=]( socket_t server ){

‎examples/37-WSS-Client.cpp‎

Lines changed: 3 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -10,26 +10,20 @@ void onMain() {
1010
ssl_t ssl; //ssl_t ssl( "./ssl/cert.key", "./ssl/cert.crt" );
1111

1212
auto client = wss::client( "wss://localhost:8000/", &ssl );
13-
auto cin = fs::std_input();
1413

1514
client.onConnect([=]( wss_t cli ){
1615

1716
console::log("connected");
1817

19-
cli.onData([]( string_t chunk ){
20-
console::log("client:>",chunk);
18+
cli.onData([]( string_t data ){
19+
console::log( data );
2120
});
2221

23-
cin.onData([=]( string_t data ){
24-
cli.write( data );
25-
});
26-
2722
cli.onDrain([=](){
2823
console::log("closed");
29-
cin.close();
3024
});
3125

32-
stream::pipe( cin );
26+
stream::pipe( cli );
3327

3428
});
3529

‎examples/38-WS.cpp‎

Lines changed: 6 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -21,23 +21,18 @@ void server(){
2121

2222
server.onConnect([=]( ws_t cli ){
2323

24-
auto cin = fs::std_input();
2524
console::log("connected");
2625

27-
cin.onData([=]( string_t data ){
28-
cli.write( data );
29-
});
30-
3126
cli.onData([=]( string_t data ){
32-
console::log( "serv:", data );
27+
cli.write( "<: received" );
28+
console::log( data );
3329
});
3430

3531
cli.onDrain([=](){
3632
console::log("closed");
37-
cin.close();
3833
});
3934

40-
stream::pipe( cin );
35+
stream::pipe( cli );
4136

4237
});
4338

@@ -56,8 +51,8 @@ void client() {
5651
auto cin = fs::std_input();
5752
console::log("connected");
5853

59-
cli.onData([]( string_t chunk ){
60-
console::log("cli:", chunk);
54+
cli.onData([]( string_t data ){
55+
console::log( data );
6156
});
6257

6358
cin.onData([=]( string_t data ){
@@ -69,6 +64,7 @@ void client() {
6964
cin.close();
7065
});
7166

67+
stream::pipe( cli );
7268
stream::pipe( cin );
7369

7470
});

‎examples/38-WSS-Server.cpp‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -34,6 +34,8 @@ void onMain(){
3434
console::log("closed");
3535
});
3636

37+
stream::pipe( cli );
38+
3739
});
3840

3941
server.listen( "localhost", 8000, [=]( ssocket_t server ){

‎examples/38-WSS.cpp‎

Lines changed: 6 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -23,23 +23,18 @@ void server(){
2323

2424
server.onConnect([=]( wss_t cli ){
2525

26-
auto cin = fs::std_input();
2726
console::log("connected");
2827

29-
cin.onData([=]( string_t data ){
30-
cli.write( data );
31-
});
32-
3328
cli.onData([=]( string_t data ){
34-
console::log( "serv:", data );
29+
cli.write( "<: received" );
30+
console::log( data );
3531
});
3632

3733
cli.onDrain([=](){
3834
console::log("closed");
39-
cin.close();
4035
});
4136

42-
stream::pipe( cin );
37+
stream::pipe( cli );
4338

4439
});
4540

@@ -60,8 +55,8 @@ void client() {
6055
auto cin = fs::std_input();
6156
console::log("connected");
6257

63-
cli.onData([]( string_t chunk ){
64-
console::log("cli:", chunk);
58+
cli.onData([]( string_t data ){
59+
console::log( data );
6560
});
6661

6762
cin.onData([=]( string_t data ){
@@ -74,6 +69,7 @@ void client() {
7469
});
7570

7671
stream::pipe( cin );
72+
stream::pipe( cli );
7773

7874
});
7975

‎examples/45-TCPClient.cpp‎

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -11,23 +11,16 @@ void onMain(){
1111
client.onOpen([=]( socket_t cli ){
1212

1313
console::log("connected", cli.get_peername() );
14-
auto cin = fs::std_input();
1514

1615
cli.onData([=]( string_t data ){
1716
console::log( data );
1817
});
1918

20-
cin.onData([=]( string_t data ){
21-
cli.write( data );
22-
});
23-
2419
cli.onClose.once([=](){
2520
console::log("closed");
26-
cin.close();
2721
});
2822

2923
stream::pipe( cli );
30-
stream::pipe( cin );
3124

3225
});
3326

‎examples/46-TCP.cpp‎

Lines changed: 1 addition & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -11,23 +11,17 @@ void server(){
1111
server.onConnect([=]( socket_t cli ){
1212

1313
console::log("connected" );
14-
auto cin = fs::std_input();
1514

1615
cli.onData([=]( string_t data ){
16+
cli.write( "<: received" );
1717
console::log( data );
1818
});
1919

20-
cin.onData([=]( string_t data ){
21-
cli.write( data );
22-
});
23-
2420
cli.onDrain.once([=](){
2521
console::log("closed");
26-
cin.close();
2722
});
2823

2924
stream::pipe( cli );
30-
stream::pipe( cin );
3125

3226
});
3327

‎examples/46-TCPServer.cpp‎

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -11,23 +11,16 @@ void onMain(){
1111
server.onConnect([=]( socket_t cli ){
1212

1313
console::log("connected", cli.get_peername() );
14-
auto cin = fs::std_input();
1514

1615
cli.onData([=]( string_t data ){
1716
console::log( data );
1817
});
1918

20-
cin.onData([=]( string_t data ){
21-
cli.write( data );
22-
});
23-
2419
cli.onDrain.once([=](){
2520
console::log("closed");
26-
cin.close();
2721
});
2822

2923
stream::pipe( cli );
30-
stream::pipe( cin );
3124

3225
});
3326

‎examples/47-UDPClient.cpp‎

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -11,23 +11,16 @@ void onMain(){
1111
client.onConnect([=]( socket_t cli ){
1212

1313
console::log("connected", cli.get_peername() );
14-
auto cin = fs::std_input();
1514

1615
cli.onData([=]( string_t data ){
1716
console::log( data );
1817
});
1918

20-
cin.onData([=]( string_t data ){
21-
cli.write( data );
22-
});
23-
2419
cli.onDrain.once([=](){
2520
console::log("closed");
26-
cin.close();
2721
});
2822

2923
stream::pipe( cli );
30-
stream::pipe( cin );
3124

3225
});
3326

0 commit comments

Comments
 (0)