View index.js
1 2 3 4 5 6 7 8 9 10
var tester = require('stream-tester');
var t2 = require('through2');
 
function dot() {
return t2.obj()
}
 
function key(k) {
return t2.obj(function(obj, _, cb) {
console.log('key ' + k + ' ' + (typeof obj) + JSON.stringify(obj))
View index.js
1 2 3 4 5 6 7 8 9
var test = require('tape');
require('tap-browser-color')();
 
test('test', function(t) {
setTimeout(function() {
t.ok(true);
t.end();
}, 2000)
});
View index.js
1 2 3 4 5 6
var nlp = require('nlp_compromise')
var sentences = nlp.pos('Cats always follow the player');
console.log(sentences);
sentences[0].tokens.forEach(function(part) {
console.log(part.pos.tag, part.pos.description, part.normalised, part.pos_reason)
});
View index.js
1 2 3 4 5 6 7 8 9
var vash = require('vash');
var str = ''
+ 'p {\n'
+ ' @if(model.can==\'123\') {'
+ ' float-offset: 3px;'
+ ' } else {'
+ ' float-offset: 6px;'
+ ' }'
+ '}';
View index.js
1 2 3 4 5 6 7 8 9 10
// simple serial task queue. Calling .next multiple times just prompts a check
// if something is still inflight. Does not periodically check for added
// tasks in a period of inactivity
function SerialTaskQueue() {
var t = {
tasks: []
, current: null
, next: function(){
return t.current
|| (t.current = t.tasks.shift()) && t.current(function(){
View hdfs.js
1 2 3 4 5 6 7 8 9 10
var through = require('through');
var path = require('path');
var ss = require('stream-stream');
var avro = require('node-avro-io');
 
var hdfs = require('webhdfs').createClient({
host: '' // stuff goes here
});
 
avrostream2('/log/ap/2014-04-01/01/ClientEvent', hdfs)
View index.js
1 2 3 4 5 6 7 8 9 10
var test = require('tape');
var tbc = require('tap-browser-color')();
var EE = require('events');
 
/** Module begins here **/
 
/**
* Given an event emitter, such as a live('spotify:application'),
* listen for 'update' events that contain `arguments` in the emitted
* object. If those arguments match a route, call the route action.
View index.js
1 2 3 4 5 6 7 8 9 10
var bcsv = require('binary-csv')
var bxhr = require('binary-xhr')
var through = require('through')
var url = require('url')
var Buffer = require('buffer').Buffer;
var createTable = require('data-table')
var insertCSS = require('insert-css')
var concat = require('concat-stream')
 
insertCSS(createTable.css)
View index.js
1 2 3 4 5 6 7 8 9 10
var bcsv = require('binary-csv')
var bxhr = require('binary-xhr')
var bops = require('bops')
var through = require('through')
var url = require('url')
var createTable = require('data-table')
var insertCSS = require('insert-css')
var concat = require('concat-stream')
 
insertCSS(createTable.css)
View bridgetest.js
1 2 3 4 5 6 7 8 9 10
var NodeCore = require('node-corejs').NodeCore;
var Spotify = require('node-corejs').Spotify;
 
var EventEmitter = require('spotify-eventemitter');
 
var username = process.env.SP_USERNAME;
var password = process.env.SP_PASSWORD;
 
//console.log(window);
//console.log(window.constructor.prototype.navigator)
Something went wrong with that request. Please try again.