Node.js - CPU bound operations with Rx

cpu-bound.js

const RxNode = require('rx-node');
const Rx = require('rx');
const spawn = require('child_process').spawn;

RxNode.fromStream(spawn('find', ['/','-type','f','-exec', 'cat', '{}', '\+']).stdout)
	.map(x => x.toString())
	// using python
	.map(x => RxNode.fromStream(spawn('./word-count.py', [x]).stdout))
	// or using javascript
	//.map(x => RxNode.fromStream(spawn('./word-count.js', [x]).stdout))
	.mergeAll()
	.map(x => x.toString())
	.do(x => console.log(x))
	.subscribe();

word-count.js

#!/usr/bin/env node
const wordcount = {};

process.argv[2]
  .replace(/[.,?!;()"'-]/g, ' ')
  .replace(/\s+/g, ' ')
  .toLowerCase()
  .split(' ')
  .forEach(function (word) {
    if (!(wordcount.hasOwnProperty(word))) wordcount[word] = 0;
    wordcount[word]++;
  });

console.log(wordcount)

word-count.py

#!/usr/bin/env python
import sys
wordcount={}

for word in sys.argv[1].split():
    if word not in wordcount:
        wordcount[word] = 1
    else:
        wordcount[word] += 1
print (wordcount)