How to use the streamifyAll function from highland

plugin.js

GitHub: robertstettner/drone-cloudformation

0
1
2
3
4
5
6
7
8
9
10
11
'use strict';
const R = require('ramda');
const hl = require('highland');
const path = require('path');
let cfn = require('cfn').class;
let fs = hl.streamifyAll(require('fs'));


let log = console.log; // eslint-disable-line no-console


let resolveAbsolutePath = p => path.resolve(process.cwd(), p);

7

5

0

index.js

GitHub: adriaan-pelzer/aws-cfn-deploy-action

2
3
4
5
6
7
8
9
10
11
12
13
const H = require('highland');
const R = require('ramda');
const aws = require('aws-sdk');
const fs = require('fs');


const cfn = H.streamifyAll(new aws.CloudFormation());


const inputKeys = ['template', 'stack-name', 'capabilities', 'parameters'];
const DEBUG = R.isEmpty(core.getInput('debug')) ? false : true;

1

0

0

index.js

GitHub: BoffinsDev/dns-registrator

1
2
3
4
5
6
7
8
9
10
11
12
var aws = require('aws-sdk')
var _ = require('highland')
var cuid = require('cuid')
var nconf = require('nconf')


var route53 = _.streamifyAll(new aws.Route53())


nconf.argv().env().defaults({
  'health-check-protocol': 'HTTP',
  'health-check-port': 80,

0

0

7

+ 2 other calls in file

getExampleFromDynamo.js

GitHub: ttollers/penelope

4
5
6
7
8
9
10
11
12
13
14
15
const AWS = require("aws-sdk");


const docClient = new AWS.DynamoDB.DocumentClient({
  "region": "eu-west-1"
});
const dbStreams = hl.streamifyAll(docClient);


module.exports = item => dbStreams.getStream({
  TableName: "EscenicStateStore-prod-article",
  Key: item

0

0

0

build.js

GitHub: jc888/dockerondemand

10
11
12
13
14
15
16
17
18
19
20
21
var docker = new Docker({
	socketPath: '/var/run/docker.sock'
});


var dockerS = hl.streamifyAll(docker);
var JoiS = hl.streamifyAll(Joi);


function pull(name) {
	return dockerS.pullStream(name)
		.flatMap((stream) => hl(stream))

0

0

0

+ 3 other calls in file