var flyd = require('flyd')

module.exports = function (stream$) {
  var executed = false
  return flyd.combine(function (s$, self) {
    if (!executed) {
      executed = true
      self(s$())
    }
  }, [stream$])
}

var flyd = require('flyd')

module.exports = function (stream$) {
  return flyd.combine(function (s$, self) {
    self(s$())
    self.end(true);
  }, [stream$])
}

Reimplement using the end stream
Reimplement using the end stream
