const rpc = require('rpc-duplex');
 
// Creating a provider
const provider = rpc({}, {
  capitalize( str ) {
    return str.toUpperCase();
  },
  throwError( arg ) {
    throw new Error(arg);
  }
});
 
// Creating a consumer
const consumer = rpc();
 
// Connect consumer & provider
// Normally this goes through a network of sorts
provider.pipe(consumer).pipe(provider);
 
// Use provided functions
const remote = rpc.remote(consumer);
 
// Go async so you can copy-paste this code
(async () => {
  
  // Wait for functions to appear
  while(remote.capitalize) await new Promise(r=>setTimeout(r,100));
  
  // Call a remote function
  let result = await remote.capitalize('foobar');
  console.log(result); // FOOBAR
  
  // Errors are re-thrown
  try {
    await remote.throwError('hello world');    
  } catch(e) {
    console.log(e.message); // hello world
  }
  
})();