{"_id":"@actyx-contrib/ng-pond","_rev":"4-8e756aa4a61d00cf46b8ddaa961bb1a9","name":"@actyx-contrib/ng-pond","dist-tags":{"latest":"0.2.3"},"versions":{"0.1.0":{"name":"@actyx-contrib/ng-pond","version":"0.1.0","peerDependencies":{"@angular/common":"^11.0.5","@angular/core":"^11.0.5","rxjs":"~6.4","@actyx-contrib/rx-pond":"^0.2","@actyx/pond":"^2"},"dependencies":{"tslib":"^2.0.0"},"description":"<img width=\"130px\" src=\"https://raw.githubusercontent.com/actyx-contrib/ng-pond/master/icon.png?token=AATHWQJJGUJUOPPC35QA75TADMW4Y\">","_id":"@actyx-contrib/ng-pond@0.1.0","_nodeVersion":"10.16.0","_npmVersion":"6.14.4","dist":{"integrity":"sha512-uTyK+PgQUJpLRn3ssroD9w/EIymcpnr9jlg/9JfEYoQUgwKw81rjzXDrrAALWebFKWEC2X+J5qMKBTVjSll6ww==","shasum":"fa85639c40df1e3674c7fa4feef6a18237c2a392","tarball":"https://registry.npmjs.org/@actyx-contrib/ng-pond/-/ng-pond-0.1.0.tgz","fileCount":12,"unpackedSize":27492,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJgGzDCCRA9TVsSAnZWagAAZKUP/2XBRL7GRFk2yuQSDHgT\n/YdqOyWNE70pGfokxY1nYaulU54wyL1jRSgtr+tFdIw/MVOPDKLVU0BvWsCG\nQ4LdiLafVmlnVJEeXYg5Cy/uPQBPwE+KieXc7pmwOBB59jtCmVc7ZmU+ag7c\nyqX1PPahhRCbvrtkyfnwnBGW5HUItTbtEYhU9E3O3MgjPMZtHgZ1+1oKBjVX\nN5n+8e7hMwpkLdKmIJewjHFnJnwmKQZVoi4O2RewVs1UI9oYCiovIqs7+TD2\nPynBZw0y8rB/0jJtSCXpzqy2HDiB4mTZw8pPXqglIp/2DSUiAWcKFv4/NmZH\nJmVSBI59BHP7z0FerminYONKA6N94coi76VCAYWHYQNErkCYrc+Xgf6Z6qNR\nLdDzFXLU9dv9nQITLHir3HVUt9/sRL5EvDn6/arPnxRJz+JGeS0qHN5VuU8+\nbr9qLfKpKhPRIeZ/Rcy2K52QiedtNUJ03FkCJQ/Xjl2o3IEM3lm2ZW+4nSPq\nwm5vHv9Cxembs/NjGjGf94X8vL17aLV6p7gVzjkRH9nwaEuZlfu6X5fMIgjx\n9A3O/vK0pw0bafacQ80jLM4XOXX1MZ+kOeQd1lWtQBTlIYKqQrQUBRhtIGvK\nRVJu8Joe6WvfLWsLYIhVDcvXo+xyJO2v+zmPgUS6F3sve9a97aehXfrE2DJ7\nt2a9\r\n=Qvb3\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIHJTkGHeWBY0a9l3blKkjGHOc3NqomgJeztm8fMxlZylAiEA0dNRBQXSYUIwVe+yhdVe3HZ1LYokGxxU+cj0+WTy5+w="}]},"_npmUser":{"name":"alex(actyx)","email":"alex.halemba@actyx.io"},"directories":{},"maintainers":[{"name":"alex(actyx)","email":"alex.halemba@actyx.io"},{"name":"ostollmann","email":"oliver@alithia.net"},{"name":"roland.kuhn","email":"roland@actyx.io"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/ng-pond_0.1.0_1612394689932_0.5215429913145833"},"_hasShrinkwrap":false},"0.2.1":{"name":"@actyx-contrib/ng-pond","version":"0.2.1","peerDependencies":{"@angular/common":"^11.0.5","@angular/core":"^11.0.5","rxjs":"~6.4","@actyx-contrib/rx-pond":"^0.2","@actyx/pond":"^2"},"dependencies":{"tslib":"^2.0.0","@actyx-contrib/rx-pond":"^0.2","@actyx/pond":"^2"},"main":"bundles/actyx-contrib-ng-pond.umd.js","module":"fesm2015/actyx-contrib-ng-pond.js","es2015":"fesm2015/actyx-contrib-ng-pond.js","esm2015":"esm2015/actyx-contrib-ng-pond.js","fesm2015":"fesm2015/actyx-contrib-ng-pond.js","typings":"actyx-contrib-ng-pond.d.ts","metadata":"actyx-contrib-ng-pond.metadata.json","sideEffects":false,"description":"<img width=\"130px\" src=\"https://raw.githubusercontent.com/actyx-contrib/ng-pond/master/icon.png?token=AATHWQO47MDKOSROJRW3VYDADVZEW\">","_id":"@actyx-contrib/ng-pond@0.2.1","_nodeVersion":"10.16.0","_npmVersion":"6.14.4","dist":{"integrity":"sha512-XWoXygAWmzuQsDk/m7Yk19eew7BMyjOzdCCPbu98rVPI9B8m6iKApYS9FwoFNNhS5MNhu/w+KjkHAcs8+xAQ3w==","shasum":"897ee67f666a565de7184ba0904882b4e8c33e12","tarball":"https://registry.npmjs.org/@actyx-contrib/ng-pond/-/ng-pond-0.2.1.tgz","fileCount":15,"unpackedSize":236347,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJgHXIxCRA9TVsSAnZWagAAX68P/3wCh2w9zAv8C2dCw2dT\nxhxjbqvqvvVglDRapdn44yI4x6zEo5RBp/c8oVI8StNggGLp9CqSSbWrpDFh\nAfTN7lUbIPILRZUnomkakdtUC61EMRxWl+G1TBoM0SLmk9SQx0PxcXg11QU9\nSReb9nlPn2YZUCgaEGBYeCBEjdjk/gJP3V4QuQu9eOJf+TDFmuJtJs3DhGFg\nnqLS5WUByURXGtJ2A6ygs00UpYi/Tk91eK3GD0p/S76xdI0DRtytJeGbAbi6\n2XpzzNmIXtvaoqGD4WIULIgVmMWO8gW9xwYHrCz+tBof1qemi8vDxLIX3sqs\nLNhBBqySZL7pPrbZZriWkA/8NUQO2rYk9YleQgtipPfRa7SzbTQON7CZKkoS\nlixiooitqQ4t0b8QyLPtEEyPlP1DU7cI7zUalbN8pq9MhtSX6w+1HDRT0Vlp\ntKdjKlLxEnjhkBHpF0WyeqOEc0Su2pgBxB54xsodw+TlwPmQjlStj0JfMGmB\nGMIfy/55xeiRXM3LdAgyA9HSc4wTuInSAHYEoMwugXOU/uK2JUYz8feA69ZK\nd/9KNtO0ss9PxLzVF6w1DnR7uavNeTu1SDN1AO5oSnj882XEVnr6mYCi5aHj\naVULdioVX9ougCmUPEvj0Yv25K1GjYTHw74uIIVxNbd5NVb8C5ddwDSrHmPm\nEPKD\r\n=dl2N\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQDqQso492qgA+045hmi24EWt5LhvNpPku3pGBBTCHAMPgIgSH2U9qObyJfjA2KT0JJzEwLRWCXA7qIJx3pij2eKv2c="}]},"_npmUser":{"name":"alex(actyx)","email":"alex.halemba@actyx.io"},"directories":{},"maintainers":[{"name":"alex(actyx)","email":"alex.halemba@actyx.io"},{"name":"ostollmann","email":"oliver@alithia.net"},{"name":"roland.kuhn","email":"roland@actyx.io"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/ng-pond_0.2.1_1612542512586_0.9334295352156425"},"_hasShrinkwrap":false},"0.2.2":{"name":"@actyx-contrib/ng-pond","version":"0.2.2","peerDependencies":{"@angular/common":"^11.0.5","@angular/core":"^11.0.5","rxjs":"~6.4"},"dependencies":{"tslib":"^2.0.0","@actyx-contrib/rx-pond":"^0.2","@actyx-contrib/registry":"^2.0","@actyx/pond":"^2"},"main":"bundles/actyx-contrib-ng-pond.umd.js","module":"fesm2015/actyx-contrib-ng-pond.js","es2015":"fesm2015/actyx-contrib-ng-pond.js","esm2015":"esm2015/actyx-contrib-ng-pond.js","fesm2015":"fesm2015/actyx-contrib-ng-pond.js","typings":"actyx-contrib-ng-pond.d.ts","metadata":"actyx-contrib-ng-pond.metadata.json","sideEffects":false,"description":"<img width=\"130px\" src=\"https://raw.githubusercontent.com/actyx-contrib/ng-pond/master/icon.png?token=AATHWQO47MDKOSROJRW3VYDADVZEW\">","_id":"@actyx-contrib/ng-pond@0.2.2","_nodeVersion":"14.15.5","_npmVersion":"7.9.0","dist":{"integrity":"sha512-ayN0HenWeCAN1ykTBS18dfZblQGJnZgwCR4evJeTx6Hk2QKDzoYRv9/7mXQEFA+qt83ONS1oC/YzTLNuen68Yw==","shasum":"0f91900b3518a8baa5790286619d6ebdb57f84cb","tarball":"https://registry.npmjs.org/@actyx-contrib/ng-pond/-/ng-pond-0.2.2.tgz","fileCount":15,"unpackedSize":232832,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJghnc1CRA9TVsSAnZWagAA+dMQAJ8mWkTPqz3Eg+q845OE\nOzw8khevkkjxPBkDbRcCD0GTHQtR+/W4sXiS57O2zeAcAmRDUADFfwGXQJiU\nSrM7xFGgzsS7VR12XVgugyuGrxZ0o6/cvhP9WxFJAMF2jhNvuCtVb5nRkVHN\np+gVrDSQ+Mxv2Mmxj7Ujsi1C9HqqC4M562nzvhus8bp6ytPNv77DxIV4J4cv\ny4EG63UIKVHW0c/kg/uAt5uRVUvPA5lfwFSm1OY5QbrHqu45ZKtU603+tJi/\n0YqTu3bQ/EJTqiCwFlnYlqxkGQbusTRzzuQ66GM9QiLqYokwy+hAVbA6LQG5\nyw9VGlqIVmGoPLQe06BBvtC7sao82wS9G037TifH8xUi+DUc/xAICAGSeZ3p\n7bud9ekxmuZ091+PdYDR/X4yRzGdzJpYsz0DrXzNfIb4oLPMaMJ7oyhIIVLs\naQUkA0nWoSBXLFCIpWYsP8R1cPqJzJWZoasgGpI2QtQlO2lC8nEOpQH5ScSK\n7ca6CdHL7UV+ks8aSDlkjUGew9FBAKk4EaHyyfOHF+KLEcrp1da+NMBR26gd\nDFP/HLCS+ypg5wQXDn4D2bvde+6YqIMP8HPQoLPbj7BWnFkchVnVvpU3azBo\nTnLwJwuesRYLlUDqN8yQtEmmEFW4mqJpNp9qJLuEsWCCZ/d9sjLqAXagBlQ+\nobCG\r\n=+fCe\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQDg/PyAZ9rk0Vy1D4T20XzxulkUsZ1x1F/qVGCyvm3UwQIhAI70oNcaNN08UZTep6elE+tv9kgQcYYlrz0+LhcepzD9"}]},"_npmUser":{"name":"alex(actyx)","email":"alex.halemba@actyx.io"},"directories":{},"maintainers":[{"name":"alex(actyx)","email":"alex.halemba@actyx.io"},{"name":"ostollmann","email":"oliver@alithia.net"},{"name":"roland.kuhn","email":"roland@actyx.io"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/ng-pond_0.2.2_1619425076641_0.4446651801617749"},"_hasShrinkwrap":false},"0.2.3":{"name":"@actyx-contrib/ng-pond","description":"Use the Actyx Pond framework integrated as a service in your angular application","version":"0.2.3","peerDependencies":{"@angular/common":"^11.0.5","@angular/core":"^11.0.5","rxjs":"~6.4"},"dependencies":{"tslib":"^2.0.0","@actyx-contrib/rx-pond":"^0.2","@actyx-contrib/registry":"^2.0","@actyx/pond":"^2"},"main":"bundles/actyx-contrib-ng-pond.umd.js","module":"fesm2015/actyx-contrib-ng-pond.js","es2015":"fesm2015/actyx-contrib-ng-pond.js","esm2015":"esm2015/actyx-contrib-ng-pond.js","fesm2015":"fesm2015/actyx-contrib-ng-pond.js","typings":"actyx-contrib-ng-pond.d.ts","metadata":"actyx-contrib-ng-pond.metadata.json","sideEffects":false,"_id":"@actyx-contrib/ng-pond@0.2.3","_nodeVersion":"14.15.5","_npmVersion":"7.9.0","dist":{"integrity":"sha512-4Kf/f3vdZX9QJ5GfGeFIy/oSEzk+fK/r/y37l7nkd5d6IQ/Hp6t6GH0KPEQi5ACQZ0X9XhYu0xtWL5zaPVcW7Q==","shasum":"ff74070a1ccf063f147ee9e32c481a38051edfc9","tarball":"https://registry.npmjs.org/@actyx-contrib/ng-pond/-/ng-pond-0.2.3.tgz","fileCount":15,"unpackedSize":232935,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJghnm0CRA9TVsSAnZWagAAde0P/2DBZcPNWU0Eoo1ZBjmo\np6ZrzCyQrRPMFrWCU42uy/FnamaCfd93uBL4Ac/h63bBy5Tm43lhZoWWqBec\nbB31GTuryzN30XaMTna1znBvPN4LTMmrl2HT/sP9mO446k9dfxsAIEz2rf38\nv+/hUI6HV/nCyUY0aUjiqaOT5fhBKsNr38Fov7y+53LwXevw6yLuv4hhnQMH\ns9ZXM4tGULd1y00RcEv2oFkiXr2K+EdCGo0FyWiq1XyPkgfElRYT4q2g+LR0\nBUxlFkChqzR21PmwiFYAFWKuRMzJksCs2mYvSt8XT1KIE1XrmwJjyH9qZNgx\nKcaUoFJwx7BVJtXJJNAviBJPIeQRTuXtkdsPnfgD+EJzX2J0yDu2FEFv1KLa\nulMf780cMm5F2DCwfhQ23W6Y/pRfqTmGRtMnFgb8QBKXGao3uPhukQ087Mhy\no2Ul3AlWYbAHsTUw3n6+pHRc1i2IZQdT3phiuqR2nVzlPBj4T03947JaM+Ak\nVfzyEQ3ANq+Rz0vJlZDYdOCH9G2YUU5det7Wam3q1c5TySWIGgyf6GhzgSTz\n0zFVHuzfcSw0/Zsa1FXKN+xC5IyPLQThlJOfDQvozk7IXqg4Na6G5PodBi5u\nrybSbf3yOfBz/C+KTy+5oyhSLZ0zh7dU/2Fse51LBxNcHBgBhLrOpyzAVlki\n6xDW\r\n=syES\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQDtJrbqJcTeOCJatM4wMvuudzVR49o6DOwZZDmRUpVWpAIhAIYoN75HIDx+a5PjpY7KPZXPYJ12KFsm0gqUvkVq05Fb"}]},"_npmUser":{"name":"alex(actyx)","email":"alex.halemba@actyx.io"},"directories":{},"maintainers":[{"name":"alex(actyx)","email":"alex.halemba@actyx.io"},{"name":"ostollmann","email":"oliver@alithia.net"},{"name":"roland.kuhn","email":"roland@actyx.io"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/ng-pond_0.2.3_1619425715698_0.6151087418773014"},"_hasShrinkwrap":false}},"time":{"created":"2021-02-03T23:24:49.732Z","0.1.0":"2021-02-03T23:24:50.058Z","modified":"2022-04-04T11:20:23.620Z","0.2.1":"2021-02-05T16:28:33.007Z","0.2.2":"2021-04-26T08:17:56.791Z","0.2.3":"2021-04-26T08:28:35.837Z"},"maintainers":[{"name":"alex(actyx)","email":"alex.halemba@actyx.io"},{"name":"ostollmann","email":"oliver@alithia.net"},{"name":"roland.kuhn","email":"roland@actyx.io"}],"description":"Use the Actyx Pond framework integrated as a service in your angular application","readme":"<img width=\"130px\" src=\"https://raw.githubusercontent.com/actyx-contrib/ng-pond/master/icon.png?token=AATHWQO47MDKOSROJRW3VYDADVZEW\">\n\n# ng-Pond\n\nUse the Actyx Pond framework integrated as a service in your angular application. Expand your toolchain with the `ActyxPondService` to observe fish all over your application and speed up your UI projects and write distributed apps in a couple of hours.\n\n## 📦 Installation\n\nng-pond is available as a npm package.\n\n`npm install @actyx-contrib/ng-pond`\n\n## 🤓  Quick start\n\n### 🌊 ActyxPondService\n\nAdd the `ActyxPondService` to your root module as singleton instance and keep the advantage of the pond's internal caching.\n\n#### 📖 Example:\n\nFile: `app.module.ts`\n\n```typescript\nimport { AppComponent } from './app.component';\nimport { ActyxPondService } from '@actyx-contrib/ng-pond'\n\n@NgModule({\n  declarations: [AppComponent],\n  imports: [BrowserModule],\n  providers: [ActyxPondService],\n  bootstrap: [AppComponent]\n})\nexport class AppModule {}\n```\n\n### 🐟 Use the pond api\n\nUse the simple pond api in your components as with callbacks or with rxjs observables. This will give you the opportunity to use your fish states in the code or use `async` pipelines to build reactive and state of the art user interfaces.\n\n> **Note**: It is highly recommended to build applications in  *separation of concerns* [(SoC)](https://en.wikipedia.org/wiki/Separation_of_concerns). Using the `PondService` directly in the components makes it harder to maintain your project and write e2e and unit tests for your components.\n\n#### 📖 Example:\n\n##### Logic:\n\nFile: `app.component.ts`\n\n```typescript\nimport { Component } from '@angular/core';\nimport { ActyxPondService } from '@actyx-contrib/ng-pond'\nimport { MachineFish, State } from '../fish/MachineFish';\nimport { Observable } from 'rxjs';\nimport { ConnectivityStatus } from '@actyx/pond';\n\n@Component({\n  selector: 'app-root',\n  templateUrl: './app.component.html'\n})\nexport class AppComponent {\n  machine$: Observable<State>\n  connectivity$: Observable<ConnectivityStatus>\n\n  constructor(private pondService: ActyxPondService) {\n    this.machine$ = this.pondService.observe$(MachineFish.of('Machine1'))\n    this.connectivity$ = this.pondService.getNodeConnectivity$()\n  }\n\n  async start() {\n    const pond = await this.pondService.getPond()\n    MachineFish.emitProdStartedEvent(pond, 'Machine1', 'order1')\n  }\n\n  async stop() {\n    const pond = await this.pondService.getPond()\n    MachineFish.emitProdStoppedEvent(pond, 'Machine1', 'order1')\n  }\n}\n```\n\n##### Template:\n\nFile: `app.component.html`\n\n```html\n<h1>Angular - Actyx-Pond - Machine control</h1>\n<div *ngIf=\"connectivity$ | async as connectivity\">\n  <h2>Connectivity: {{connectivity.status | json}}</h2>\n</div>\n<div *ngIf=\"machine$ | async as machine; else loading\">\n  <div>\n    <h2>Machine {{machine.machineId}}</h2>\n    <dl>\n      <dt>state:</dt>\n      <dd>{{machine.state}}</dd>\n    </dl>\n  </div>\n  <button *ngIf=\"machine.state==='stopped'\" (click)=\"start()\">start</button>\n  <button *ngIf=\"machine.state==='started'\" (click)=\"stop()\">stop</button>\n</div>\n<ng-template #loading>Loading machine data...</ng-template>\n```\n\n##### 🐟 Fish\n\nFile: `MachineFish.ts`\n\n```typescript\nimport { Fish, FishId, Pond, Tag } from '@actyx/pond'\nexport type State =\n  | { state: 'idle', machineId: string }\n  | { state: 'inProduction', machineId: string, orderId: string }\nexport type Event =\n  | { eventType: 'prodStarted', machineId: string, orderId: string }\n  | { eventType: 'prodStopped', machineId: string, orderId: string }\n\nconst machineTag = Tag<Event>('machine')\n\nexport const MachineFish = {\n  tags: { machineTag },\n  of: (machineId: string): Fish<State, Event> => ({\n    fishId: FishId.of('machineFish', machineId, 0),\n    initialState: { state: 'idle', machineId },\n    where: machineTag.withId(machineId),\n    onEvent: (state, event) => {\n      switch (event.eventType) {\n        case 'prodStarted':\n          return {\n            state: 'inProduction',\n            machineId: state.machineId,\n            orderId: event.orderId,\n          }\n        case 'prodStopped':\n          return {\n            state: 'idle',\n            machineId: state.machineId,\n          }\n      }\n      return state\n    },\n  }),\n  emitProdStoppedEvent: (pond: Pond, machineId: string, orderId: string) =>\n    pond.emit(\n      machineTag.withId(machineId),\n      { eventType: 'prodStopped', machineId, orderId }\n    ),\n  emitProdStartedEvent: (pond: Pond, machineId: string, orderId: string) =>\n    pond.emit(\n      machineTag.withId(machineId),\n      { eventType: 'prodStarted', machineId, orderId }\n    ),\n}\n\n```\n\n### Registry fish\n\nIn the pond, there are two ways to create registry fish. `observeAll` and `observe` a registry fish and map the entity fish as a second step. In the matter that `observeAll` is pretty strate forward, here is an example for the registry fish.\n\n#### 📖 Example:\n\n> **Note**: This example is build on top of the `Use the pond api` example above.\n\n##### Logic:\n\nFile: `app.component.ts`\n\n```typescript\n// [..]\n  allMachines$: Observable<ReadonlyArray<State>>\n\n  constructor(private pondService: ActyxPondService) {\n    this.machine$ = this.pondService.observe$(MachineFish.of('Machine1'))\n    this.allMachine$ = this.pondService.observeRegistry$(MachineFish.registry(), s => s, MachineFish.of)\n    this.connectivity$ = this.pondService.getNodeConnectivity$()\n  }\n// [..]\n}\n```\n\n##### Template:\n\nFile: `app.component.html`\n\n```html\n<!-- [..] -->\n<div *ngFor=\"let machine of (allMachines$ | async)\">\n  <dl>\n    <dt>Name:</dt>\n    <dd>{{machine.machineId}}</dd>\n    <dt>State:</dt>\n    <dd>{{machine.state}}</dd>\n  </dl>\n</div>\n<!-- [..] -->\n```\n\n##### 🐟 Fish\n\nFile: `MachineFish.ts`\n\n```typescript\nexport const MachineFish = {\n  // [..]\n  registry: (): Fish<string[], Event> => ({\n    fishId: FishId.of('machineRegFish', 'reg', 0),\n    initialState: [],\n    where: machineTag,\n    onEvent: (state, event) => {\n      if (!state.includes(event.machineId)) {\n        state.push(event.machineId)\n      }\n      return state\n    },\n  }),\n  // [..]\n```\n\n\n## 📖 Service overview\n\n> Check out the documentation about the Actyx-Pond to get more detailed information https://developer.actyx.com/docs/pond/introduction/\n\nYou are going to find a detailed api documentation in the definition file of the package.\n\n### TS/JS Promise interface:\n\n - getPond()\n - emit(tags, event)\n - observe(fish, onStateChanged)\n - observeRegistry(registryFish, mapToProperty, makeEntityFish, onStateChanged)\n - observeAll(seedEventsSelector, makeFish, opts, onStateChanged)\n - observeOne(seedEventSelector, makeFish, onStateChanged, stoppedByError)\n - getPondState(callback)\n - pondInfo()\n - run(fish, fn)\n - keepRunning(fish, fn, autoCancel)\n\n### RxJs integration:\n\n> **Note**: _Not every function has a RxJs wrapper. In this case, please use the one from above._\n\n - getRxPond()\n - observeRegistry$(registryFish, mapToProperty, makeEntityFish)\n - observe$(fish)\n - observeAll$(seedEventsSelector, makeFish, opts)\n - observeOne$(seedEventsSelector, makeFish)\n - getPondState$()\n - getNodeConnectivity$()\n - waitForSwarmSync$()\n - run$(fish, fn)\n","readmeFilename":"README.md"}