highland-example.js

var findContract = _.flip(_.wrapCallback(Contract.findById.bind(Contract)), {remoteCtx: ctx});
var findContractPeriods = _.flip(_.wrapCallback(ContractPeriod.find.bind(ContractPeriod)), {remoteCtx: ctx});
var findContractPeriod = _.flip(_.wrapCallback(ContractPeriod.findById.bind(ContractPeriod)), {remoteCtx: ctx});
var findReviews = _.flip(_.wrapCallback(Review.find.bind(Review)), {remoteCtx: ctx});
var sendEmail = _.wrapCallback(sendReminderEmail);

var contractPeriodStream1 = findReviews(query).flatten().pluck('contractPeriodId').map(findContractPeriod);
var contractPeriodStream2 = findContractPeriods(query).flatten();

contractPeriodStream1.merge(contractPeriodStream2)
  .pluck('contractId').uniq()
  .map(findContract).flatten()
  .map(sendEmail).flatten()
  .errors(cb)
  .done(cb)