.findWhere()

src/index.js

@@ -54,4 +54,5 @@ _.extend('toArray', function (fn) { return _.toArray(fn, this) })
 _.extend('toPromise', function () { return _.toPromise(this) })
 _.extend('toNodeStream', function (options) { return _.toNodeStream(options, this) })
 _.extend('where', function (props) { return _.where(props, this) })
+_.extend('findWhere', function (props) { return _.findWhere(props, this) })
 _.extend('ratelimit', function (num, ms) { return _.ratelimit(num, ms, this) })

src/methods.js

@@ -97,6 +97,8 @@ _m.where = _.curry((props, s) => s.filter(x => {
   return true
 }))
 
+_m.findWhere = _.curry((props, s) => s.where(props).take(1))
+
 _m.ratelimit = _.curry((num, ms, s) => {
   let sent = 0
   let startWindow

test/errors.test.js

@@ -330,6 +330,7 @@ test('error propagation', async () => {
     .csvStringify()
     .head()
     .last()
+    .findWhere()
     .resolve()
     .slice(1, 3)
     .makeAsync(10)

test/exstream.test.js

@@ -747,6 +747,13 @@ test('where', () => {
   expect(res).toEqual([{ a: 'a', b: 'b' }])
 })
 
+test('findWhere', () => {
+  const res = _([{ a: 'a', b: 'b' }, { a: 'b', b: 'c' }, { a: 'a', b: 'b' }])
+    .findWhere({ a: 'a' })
+    .value()
+  expect(res).toEqual({ a: 'a', b: 'b' })
+})
+
 test('multipipe', () => new Promise(resolve => {
   // This demonstrates how to pipe multiple input streams into an exstream writer. You can even control parallelism
   // and order. The whole chain has back-pressure