Function

Funcion que permite añadir librerias externas para cargar dinamicamente nuevos comandos y observadores la funcion recibe como parametro la ruta del fichero a cargar siguiendo el siguiente patron ${type}/${mapLib}@${version}/${action.key} y la funcion tiene que hacer el import dinamico import()

Example:

RxMap.addImportLib('test',arg => import(`../lib/${arg}`));

Recupera la lista de acciones registradas

Recupera la lista de funciones registradas

Funcion que puede recibir un string con el nombre del obsevador que se quiere recuperar de los registrados o que puede recibir un Array, una promesa o un Iterable o otro Observebable sobre el que devuelve un observable con el CommandBus aplicado para poder invocar los comandos.

Al observador se le pueden pasar los argumentos que necesite.

Example:

 // String

RxMap.observer('test')
 .example('test')
 .subscribe(console.log);

 // Array
RxMap.observer([1,2,3,4,5])
 .example('test')
 .subscribe(console.log);

const $stream = from(['a','b','c']);
RxMap.observer($stream)
 .example('test')
 .subscribe(console.log);

Permite registrar las acciones que luego se podra utilizar en @link {RxMap} o desde los Observadores

• @example // Registrar accion registerAction'test',arg=>console.log(arg));

  // Utilizar el comando RxMap.test('asasfasdf'); RxMap.fromObserver(from(5)).test('asfadf').subscribe(console.log)

Permite registrar las funciones que luego se podra utilizar en @link {RxMap}

• @example // Registrar accion registerFunction'test',arg=>console.log(arg));

  // Utilizar el comando RxMap.test('asasfasdf');

Funcion que permite registrar librerias de Comandos y Observadores

Solo se registran los comamdos y los observadores que se pasen en los parametros, si ya existiera un comando o observador con el mismo nombre lo sobreescribiria.

La funcion recibira los parametros ( type, mapLib, version, key ) para indicar lo que se quiere recuperar. Y tiene que devolver de manera asyncrona( async, promise ) un objeto con la funcion del comando o el observador el valor "default" o en el valor del nombre del comando o observador. Esta funcion tiene que cargar el codigo en la aplicación la manera más aconsejado es con un import dynamico

Example:

Ejemplo de Funcion import dinamico
(type, mapLib, version, key) => import( `../lib/${type}/${mapLib}@${version}/${key}`));

funcion que permite registar los middlewares, para realizar acciones antes y depués de ejecutar una acción, se puden pasar mas de un middlleware . El primer parametro es opcional y es el nombre de la acción sobre la que se va a aplicar el middleware, si no se pasa ningun nombre se aplicará sobre todas las acciones.

Example:

registerMiddleware('test',middleware1,middleware2);

registerMiddleware(middleware1,middleware2);

Las funciones del midleware son funciones que revien la accion a ejecutar y devuelve una
función async que recibe como parametro el CommandBus y un array con los argumentos
La función tiene que hacer lo que quiera, ejecutar la acción, volver a ejecutar el código
que desee y devolver el resultado de la acción ejecutada.

const LoggerMiddleware = next => async (Map, args) => {
 const actionName = Map.getActionName();
 const now = new Date().getTime();
 const name = `Command ${actionName} [${now}]: `;
 console.log(`Pre ${name}`, args);
 const res = await next(Map, args);
 console.log(`Post ${name}`, res);
 return res;
};
registerMiddleware(LoggerMiddleware);

Funcion que permite registrar los observadores que luego se podran utilzar desde el metodo RxMap.observer({name}). La funcion tiene que devolver un objeto observable de RxJs

Example:

 // Registrar observador
 registerObserver('gps',()=>from('5'));

 // Utilizar observador
 RxMap.observer('gps').subscribe(cosole.log);