How to use the of function from highland

plugin.js

GitHub: robertstettner/drone-cloudformation

8
9
10
11
12
13
14
15
16
17
18
19


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


let resolveTemplate = template => {
    if (!/https:\/\//.test(template)) {
        return hl.of(template)
            .map(resolveAbsolutePath)
            .flatMap(fs.statStream);
    } else {
        return hl.of(1);

7

5

0

+ 25 other calls in file

cli.js

GitHub: protometa/blipper

23
24
25
26
27
28
29
30
31
32
    return (post.author.username || post.author.id) + ' - ' + (new Date(post.time)).toString() + '\n' +
    '  ' + post.content + '\n'
  })
},
help: function () {
  return _.of(
    'usage: blipper <command> [<arg>]\n' +
    'commands:\n' +
    '  name     Set your username\n' +
    '  about    Set your about info\n' +

1

1

0

util.js

GitHub: clay/clay-reindexer

41
42
43
44
45
46
47
48
49
    return push(new Error(message));
  };
}

function errIfNotOk(res) {
  if (res.ok) return h.of(res);
  return h(res.text()) // you must read the response to close the client
    .map(() => {
      const err = new Error();

1

0

16

+ 7 other calls in file

utils.js

GitHub: amsross/io-mattross-transitland

27
28
29
30
31
32
33
34
35
36
37
  return h.wrapCallback(q.get, r.nthArg(1))(url)
    .map(JSON.parse)
}


module.exports.matchAgainst = fuseConfig => recurse => match => prop => response => {
  return h.of(response)
    .map(r.prop(prop))
    .map(r.map(r.reject(r.isNil)))
    .flatMap(r.pipe(
      r.construct(F)(r.__, fuseConfig),

0

1

0

+ 2 other calls in file

schedules.js

GitHub: amsross/io-mattross-transitland

5
6
7
8
9
10
11
12
13
14
15
16
const { get, mutateUrl } = require('./utils')


const baseUrl = url.parse('https://transit.land/api/v1/schedule_stop_pairs?offset=0&per_page=50&sort_key=origin_departure_time&sort_order=asc&origin_onestop_id=foo&origin_departure_between=foo&service_from_date=foo', true)


module.exports = function (options) {
  const getSchedules = stop => url => h.of(url)
    .map(r.compose(
      r.over(r.lensProp('query'), r.reject(r.isNil)),
      r.set(r.lensPath(['query', 'origin_onestop_id']), r.prop('onestop_id')(stop)),
      r.over(r.lensPath(['query', 'origin_departure_between']), () => {

0

1

0