Compare commits
2 Commits
Author | SHA1 | Date | |
---|---|---|---|
4969a703da | |||
5e16294773 |
@ -6,8 +6,8 @@ on:
|
|||||||
- '**'
|
- '**'
|
||||||
|
|
||||||
env:
|
env:
|
||||||
IMAGE: registry.gitlab.com/hosttoday/ht-docker-node:npmci
|
IMAGE: code.foss.global/host.today/ht-docker-node:npmci
|
||||||
NPMCI_COMPUTED_REPOURL: https://${{gitea.repository_owner}}:${{secrets.GITEA_TOKEN}}@gitea.lossless.digital/${{gitea.repository}}.git
|
NPMCI_COMPUTED_REPOURL: https://${{gitea.repository_owner}}:${{secrets.GITEA_TOKEN}}@/${{gitea.repository}}.git
|
||||||
NPMCI_TOKEN_NPM: ${{secrets.NPMCI_TOKEN_NPM}}
|
NPMCI_TOKEN_NPM: ${{secrets.NPMCI_TOKEN_NPM}}
|
||||||
NPMCI_TOKEN_NPM2: ${{secrets.NPMCI_TOKEN_NPM2}}
|
NPMCI_TOKEN_NPM2: ${{secrets.NPMCI_TOKEN_NPM2}}
|
||||||
NPMCI_GIT_GITHUBTOKEN: ${{secrets.NPMCI_GIT_GITHUBTOKEN}}
|
NPMCI_GIT_GITHUBTOKEN: ${{secrets.NPMCI_GIT_GITHUBTOKEN}}
|
||||||
@ -26,7 +26,7 @@ jobs:
|
|||||||
- name: Install pnpm and npmci
|
- name: Install pnpm and npmci
|
||||||
run: |
|
run: |
|
||||||
pnpm install -g pnpm
|
pnpm install -g pnpm
|
||||||
pnpm install -g @shipzone/npmci
|
pnpm install -g @ship.zone/npmci
|
||||||
|
|
||||||
- name: Run npm prepare
|
- name: Run npm prepare
|
||||||
run: npmci npm prepare
|
run: npmci npm prepare
|
||||||
|
@ -6,8 +6,8 @@ on:
|
|||||||
- '*'
|
- '*'
|
||||||
|
|
||||||
env:
|
env:
|
||||||
IMAGE: registry.gitlab.com/hosttoday/ht-docker-node:npmci
|
IMAGE: code.foss.global/host.today/ht-docker-node:npmci
|
||||||
NPMCI_COMPUTED_REPOURL: https://${{gitea.repository_owner}}:${{secrets.GITEA_TOKEN}}@gitea.lossless.digital/${{gitea.repository}}.git
|
NPMCI_COMPUTED_REPOURL: https://${{gitea.repository_owner}}:${{secrets.GITEA_TOKEN}}@/${{gitea.repository}}.git
|
||||||
NPMCI_TOKEN_NPM: ${{secrets.NPMCI_TOKEN_NPM}}
|
NPMCI_TOKEN_NPM: ${{secrets.NPMCI_TOKEN_NPM}}
|
||||||
NPMCI_TOKEN_NPM2: ${{secrets.NPMCI_TOKEN_NPM2}}
|
NPMCI_TOKEN_NPM2: ${{secrets.NPMCI_TOKEN_NPM2}}
|
||||||
NPMCI_GIT_GITHUBTOKEN: ${{secrets.NPMCI_GIT_GITHUBTOKEN}}
|
NPMCI_GIT_GITHUBTOKEN: ${{secrets.NPMCI_GIT_GITHUBTOKEN}}
|
||||||
@ -26,7 +26,7 @@ jobs:
|
|||||||
- name: Prepare
|
- name: Prepare
|
||||||
run: |
|
run: |
|
||||||
pnpm install -g pnpm
|
pnpm install -g pnpm
|
||||||
pnpm install -g @shipzone/npmci
|
pnpm install -g @ship.zone/npmci
|
||||||
npmci npm prepare
|
npmci npm prepare
|
||||||
|
|
||||||
- name: Audit production dependencies
|
- name: Audit production dependencies
|
||||||
@ -54,7 +54,7 @@ jobs:
|
|||||||
- name: Prepare
|
- name: Prepare
|
||||||
run: |
|
run: |
|
||||||
pnpm install -g pnpm
|
pnpm install -g pnpm
|
||||||
pnpm install -g @shipzone/npmci
|
pnpm install -g @ship.zone/npmci
|
||||||
npmci npm prepare
|
npmci npm prepare
|
||||||
|
|
||||||
- name: Test stable
|
- name: Test stable
|
||||||
@ -82,7 +82,7 @@ jobs:
|
|||||||
- name: Prepare
|
- name: Prepare
|
||||||
run: |
|
run: |
|
||||||
pnpm install -g pnpm
|
pnpm install -g pnpm
|
||||||
pnpm install -g @shipzone/npmci
|
pnpm install -g @ship.zone/npmci
|
||||||
npmci npm prepare
|
npmci npm prepare
|
||||||
|
|
||||||
- name: Release
|
- name: Release
|
||||||
@ -104,7 +104,7 @@ jobs:
|
|||||||
- name: Prepare
|
- name: Prepare
|
||||||
run: |
|
run: |
|
||||||
pnpm install -g pnpm
|
pnpm install -g pnpm
|
||||||
pnpm install -g @shipzone/npmci
|
pnpm install -g @ship.zone/npmci
|
||||||
npmci npm prepare
|
npmci npm prepare
|
||||||
|
|
||||||
- name: Code quality
|
- name: Code quality
|
||||||
@ -119,6 +119,6 @@ jobs:
|
|||||||
run: |
|
run: |
|
||||||
npmci node install stable
|
npmci node install stable
|
||||||
npmci npm install
|
npmci npm install
|
||||||
pnpm install -g @gitzone/tsdoc
|
pnpm install -g @git.zone/tsdoc
|
||||||
npmci command tsdoc
|
npmci command tsdoc
|
||||||
continue-on-error: true
|
continue-on-error: true
|
||||||
|
3
.gitignore
vendored
3
.gitignore
vendored
@ -3,7 +3,6 @@
|
|||||||
# artifacts
|
# artifacts
|
||||||
coverage/
|
coverage/
|
||||||
public/
|
public/
|
||||||
pages/
|
|
||||||
|
|
||||||
# installs
|
# installs
|
||||||
node_modules/
|
node_modules/
|
||||||
@ -17,4 +16,4 @@ node_modules/
|
|||||||
dist/
|
dist/
|
||||||
dist_*/
|
dist_*/
|
||||||
|
|
||||||
# custom
|
#------# custom
|
@ -1,5 +1,14 @@
|
|||||||
# Changelog
|
# Changelog
|
||||||
|
|
||||||
|
## 2025-04-25 - 3.0.10 - fix(ci)
|
||||||
|
Update CI workflows, dependency versions, and TypeScript configuration
|
||||||
|
|
||||||
|
- Updated .gitea workflow files: changed IMAGE URL and npmci package name (@shipzone/npmci to @ship.zone/npmci)
|
||||||
|
- Upgraded development dependencies from @gitzone/* to @git.zone/* packages
|
||||||
|
- Enhanced tsconfig.json with emitDecoratorMetadata, baseUrl, and paths
|
||||||
|
- Minor code formatting improvements and trailing comma adjustments in TypeScript files
|
||||||
|
- Updated package.json homepage and added bugs/overrides configuration
|
||||||
|
|
||||||
## 2025-04-25 - 3.0.9 - fix(deps/ts_plugins)
|
## 2025-04-25 - 3.0.9 - fix(deps/ts_plugins)
|
||||||
Update @types/node dependency and adjust rxjs operator exports ordering
|
Update @types/node dependency and adjust rxjs operator exports ordering
|
||||||
|
|
||||||
|
20
package.json
20
package.json
@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "@push.rocks/smartrx",
|
"name": "@push.rocks/smartrx",
|
||||||
"version": "3.0.9",
|
"version": "3.0.10",
|
||||||
"private": false,
|
"private": false,
|
||||||
"description": "A smart wrapper for rxjs to manage and extend observables.",
|
"description": "A smart wrapper for rxjs to manage and extend observables.",
|
||||||
"main": "dist_ts/index.js",
|
"main": "dist_ts/index.js",
|
||||||
@ -14,10 +14,10 @@
|
|||||||
"buildDocs": "tsdoc"
|
"buildDocs": "tsdoc"
|
||||||
},
|
},
|
||||||
"devDependencies": {
|
"devDependencies": {
|
||||||
"@gitzone/tsbuild": "^2.1.66",
|
"@git.zone/tsbuild": "^2.3.2",
|
||||||
"@gitzone/tsbundle": "^2.0.8",
|
"@git.zone/tsbundle": "^2.2.5",
|
||||||
"@gitzone/tsrun": "^1.2.44",
|
"@git.zone/tsrun": "^1.3.3",
|
||||||
"@gitzone/tstest": "^1.0.77",
|
"@git.zone/tstest": "^1.0.96",
|
||||||
"@push.rocks/tapbundle": "^5.0.15",
|
"@push.rocks/tapbundle": "^5.0.15",
|
||||||
"@types/node": "^22.15.2"
|
"@types/node": "^22.15.2"
|
||||||
},
|
},
|
||||||
@ -50,10 +50,16 @@
|
|||||||
"backpressure",
|
"backpressure",
|
||||||
"event handling"
|
"event handling"
|
||||||
],
|
],
|
||||||
"homepage": "https://code.foss.global/push.rocks/smartrx",
|
"homepage": "https://code.foss.global/push.rocks/smartrx#readme",
|
||||||
"repository": {
|
"repository": {
|
||||||
"type": "git",
|
"type": "git",
|
||||||
"url": "https://code.foss.global/push.rocks/smartrx.git"
|
"url": "https://code.foss.global/push.rocks/smartrx.git"
|
||||||
},
|
},
|
||||||
"packageManager": "pnpm@10.7.0+sha512.6b865ad4b62a1d9842b61d674a393903b871d9244954f652b8842c2b553c72176b278f64c463e52d40fff8aba385c235c8c9ecf5cc7de4fd78b8bb6d49633ab6"
|
"packageManager": "pnpm@10.7.0+sha512.6b865ad4b62a1d9842b61d674a393903b871d9244954f652b8842c2b553c72176b278f64c463e52d40fff8aba385c235c8c9ecf5cc7de4fd78b8bb6d49633ab6",
|
||||||
|
"bugs": {
|
||||||
|
"url": "https://code.foss.global/push.rocks/smartrx/issues"
|
||||||
|
},
|
||||||
|
"pnpm": {
|
||||||
|
"overrides": {}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
3245
pnpm-lock.yaml
generated
3245
pnpm-lock.yaml
generated
File diff suppressed because it is too large
Load Diff
@ -84,7 +84,6 @@ observableIntake.signalComplete();
|
|||||||
|
|
||||||
`ObservableIntake` offers the flexibility of adding values as they come and controlling when those values are emitted to subscribers, including buffering capabilities for managing backpressure.
|
`ObservableIntake` offers the flexibility of adding values as they come and controlling when those values are emitted to subscribers, including buffering capabilities for managing backpressure.
|
||||||
|
|
||||||
|
|
||||||
#### Advanced Use-cases
|
#### Advanced Use-cases
|
||||||
|
|
||||||
`@push.rocks/smartrx` is built to handle more sophisticated scenarios like working with streams or handling events in a web environment.
|
`@push.rocks/smartrx` is built to handle more sophisticated scenarios like working with streams or handling events in a web environment.
|
||||||
|
@ -3,6 +3,6 @@
|
|||||||
*/
|
*/
|
||||||
export const commitinfo = {
|
export const commitinfo = {
|
||||||
name: '@push.rocks/smartrx',
|
name: '@push.rocks/smartrx',
|
||||||
version: '3.0.9',
|
version: '3.0.10',
|
||||||
description: 'A smart wrapper for rxjs to manage and extend observables.'
|
description: 'A smart wrapper for rxjs to manage and extend observables.'
|
||||||
}
|
}
|
||||||
|
@ -29,7 +29,7 @@ export class Observablemap {
|
|||||||
*/
|
*/
|
||||||
public getSubjectForEmitterEvent<T>(
|
public getSubjectForEmitterEvent<T>(
|
||||||
emitterArg: IEventEmitter<T>,
|
emitterArg: IEventEmitter<T>,
|
||||||
eventArg: string
|
eventArg: string,
|
||||||
): rxjs.Subject<T> {
|
): rxjs.Subject<T> {
|
||||||
const existingBundle = this.observableEventEmitterBundleArray.find((bundleArg) => {
|
const existingBundle = this.observableEventEmitterBundleArray.find((bundleArg) => {
|
||||||
return bundleArg.eventRef === emitterArg && bundleArg.event === eventArg;
|
return bundleArg.eventRef === emitterArg && bundleArg.event === eventArg;
|
||||||
@ -52,7 +52,7 @@ export class Observablemap {
|
|||||||
|
|
||||||
public getSubjectForEventTarget<T>(
|
public getSubjectForEventTarget<T>(
|
||||||
eventTargetArg: EventTarget,
|
eventTargetArg: EventTarget,
|
||||||
eventNameArg: string
|
eventNameArg: string,
|
||||||
): rxjs.Subject<T> {
|
): rxjs.Subject<T> {
|
||||||
const existingBundle = this.observableEventTargetBundleArray.find((bundleArg) => {
|
const existingBundle = this.observableEventTargetBundleArray.find((bundleArg) => {
|
||||||
return bundleArg.eventRef === eventTargetArg && bundleArg.event === eventNameArg;
|
return bundleArg.eventRef === eventTargetArg && bundleArg.event === eventNameArg;
|
||||||
|
@ -1,5 +1,5 @@
|
|||||||
import { Observable } from 'rxjs';
|
import { Observable } from 'rxjs';
|
||||||
import { Readable } from 'stream';
|
import type { Readable } from 'stream';
|
||||||
|
|
||||||
export function fromStreamWithBackpressure<T>(stream: Readable): Observable<T> {
|
export function fromStreamWithBackpressure<T>(stream: Readable): Observable<T> {
|
||||||
return new Observable<T>((subscriber) => {
|
return new Observable<T>((subscriber) => {
|
||||||
|
@ -4,7 +4,18 @@ export { Observable, Subject, fromEvent, ReplaySubject, Subscription, from, of }
|
|||||||
|
|
||||||
export type { Observer } from 'rxjs';
|
export type { Observer } from 'rxjs';
|
||||||
|
|
||||||
import { buffer, bufferCount, bufferTime, debounce, debounceTime, filter, map, startWith, takeUntil, throttleTime } from 'rxjs/operators';
|
import {
|
||||||
|
buffer,
|
||||||
|
bufferCount,
|
||||||
|
bufferTime,
|
||||||
|
debounce,
|
||||||
|
debounceTime,
|
||||||
|
filter,
|
||||||
|
map,
|
||||||
|
startWith,
|
||||||
|
takeUntil,
|
||||||
|
throttleTime,
|
||||||
|
} from 'rxjs/operators';
|
||||||
|
|
||||||
export const ops = {
|
export const ops = {
|
||||||
buffer,
|
buffer,
|
||||||
@ -16,5 +27,5 @@ export const ops = {
|
|||||||
map,
|
map,
|
||||||
startWith,
|
startWith,
|
||||||
takeUntil,
|
takeUntil,
|
||||||
throttleTime
|
throttleTime,
|
||||||
};
|
};
|
||||||
|
@ -1,12 +1,15 @@
|
|||||||
{
|
{
|
||||||
"compilerOptions": {
|
"compilerOptions": {
|
||||||
"experimentalDecorators": true,
|
"experimentalDecorators": true,
|
||||||
|
"emitDecoratorMetadata": true,
|
||||||
"useDefineForClassFields": false,
|
"useDefineForClassFields": false,
|
||||||
"target": "ES2022",
|
"target": "ES2022",
|
||||||
"module": "NodeNext",
|
"module": "NodeNext",
|
||||||
"moduleResolution": "NodeNext",
|
"moduleResolution": "NodeNext",
|
||||||
"esModuleInterop": true,
|
"esModuleInterop": true,
|
||||||
"verbatimModuleSyntax": true
|
"verbatimModuleSyntax": true,
|
||||||
|
"baseUrl": ".",
|
||||||
|
"paths": {}
|
||||||
},
|
},
|
||||||
"exclude": [
|
"exclude": [
|
||||||
"dist_*/**/*.d.ts"
|
"dist_*/**/*.d.ts"
|
||||||
|
Loading…
x
Reference in New Issue
Block a user