rsocket-adapter-rxjs
Advanced tools
Comparing version 1.0.0-alpha.3 to 1.0.0-alpha.4
@@ -84,6 +84,13 @@ /* | ||
if (scheduler === void 0) { scheduler = rxjs_1.asyncScheduler; } | ||
var once = false; | ||
var _a = __read((0, rxjs_1.partition)(datas.pipe((0, rxjs_1.share)({ | ||
connector: function () { return new rxjs_1.Subject(); }, | ||
resetOnRefCountZero: true, | ||
})), function (_value, index) { return index === 0; }), 2), firstValueObservable = _a[0], restValuesObservable = _a[1]; | ||
})), function (_value) { | ||
var previous = once; | ||
if (!previous) { | ||
once = true; | ||
} | ||
return !previous; | ||
}), 2), firstValueObservable = _a[0], restValuesObservable = _a[1]; | ||
return function (rsocket, metadata) { | ||
@@ -90,0 +97,0 @@ var encodedMetadata = metadata ? (0, rsocket_composite_metadata_1.encodeCompositeMetadata)(metadata) : null; |
{ | ||
"name": "rsocket-adapter-rxjs", | ||
"version": "1.0.0-alpha.3", | ||
"version": "1.0.0-alpha.4", | ||
"license": "Apache-2.0", | ||
@@ -30,3 +30,3 @@ "main": "dist/index", | ||
}, | ||
"gitHead": "7dc895fd0eb6c6c3f7ab9a945525f64a8df80bd1" | ||
"gitHead": "f734934b3f0ecd599cc4510e5cf37606eb102096" | ||
} |
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
69046
835