File tree Expand file tree Collapse file tree 2 files changed +4
-2
lines changed Expand file tree Collapse file tree 2 files changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -21,6 +21,8 @@ const client = new RSocketConnector({
21
21
setup : {
22
22
dataMimeType : 'application/bson' ,
23
23
metadataMimeType : 'application/bson' ,
24
+ keepAlive : 15_000 ,
25
+ lifetime : 120_000 ,
24
26
payload : {
25
27
data : null ,
26
28
metadata : Buffer . from (
@@ -51,7 +53,7 @@ const stream = rsocket.requestStream(
51
53
SYNC_QUEUE_REQUEST_N , // The initial N amount
52
54
{
53
55
onError : ( e ) => {
54
- console . error ( e ) ;
56
+ console . error ( new Date ( ) . toISOString ( ) , i , e ) ;
55
57
} ,
56
58
onNext : ( payload ) => {
57
59
const { data } = payload ;
Original file line number Diff line number Diff line change 8
8
"sourceMap" : true
9
9
},
10
10
"include" : [" src" ],
11
- "references" : []
11
+ "references" : [{ "path" : " ../packages/service-core " } ]
12
12
}
You can’t perform that action at this time.
0 commit comments