vshjxyz

function generateParametersList (name = '', params) {
  return _.chain(params)
    .uniq()
    .map((param, i) => ({ [`:${name}${i}`]: param }))
    .reduce((acc, curr) => ({ ...acc, ...curr }))
    .value()
}

const typesMapping = generateParametersList('type', types)
  

vshjxyz

import { Observable } from 'rxjs'
import {
  MutatorIO,
  InputStream,
  OutputStream
} from 'mutator-io'
const myPipe = {
  name: 'myPipeName',
  in: {
    create: () => Observable.of('My message', 'My other message')

vshjxyz

mutator.transform('myPipeName', msg => `${msg} my transformation` as TransformStream)
mutator.transform('myPipeName', msg => Promise.resolve(`${msg} my transformation promise`) as TransformStream)
mutator.transform('myPipeName', msg => Observable.of(`${msg} my transformation observable`) as TransformStream)

vshjxyz

gem "octokit", "~> 4.0"