123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354 |
- 'use strict';
- module.metadata = {
- 'stability': 'experimental'
- };
- let { request: hostReq, response: hostRes } = require('./host');
- let { defer: async } = require('../lang/functional');
- let { defer } = require('../core/promise');
- let { emit: emitSync, on, off } = require('../event/core');
- let { uuid } = require('../util/uuid');
- let emit = async(emitSync);
- let requests = new Map();
- let receive = async(function ({data, id, error}) {
- let request = requests.get(id);
- if (request) {
- if (error) request.reject(error);
- else request.resolve(clone(data));
- requests.delete(id);
- }
- });
- on(hostRes, 'data', receive);
- function send (eventName, data) {
- let id = uuid();
- let deferred = defer();
- requests.set(id, deferred);
- emit(hostReq, 'data', {
- id: id,
- data: clone(data),
- event: eventName
- });
- return deferred.promise;
- }
- exports.send = send;
- function clone (obj) JSON.parse(JSON.stringify(obj || {}))
|