Skip to content

Commit

Permalink
Fix linting errors
Browse files Browse the repository at this point in the history
  • Loading branch information
jfmengels authored and godu committed May 20, 2016
1 parent 3f33edb commit 346c615
Show file tree
Hide file tree
Showing 4 changed files with 30 additions and 22 deletions.
5 changes: 3 additions & 2 deletions src/fallback.js
Original file line number Diff line number Diff line change
Expand Up @@ -18,8 +18,9 @@ const createFallback$ = filePath => {

return Observable.of(filePath)
.flatMap(filePath => readFile$(filePath, {
encoding: 'UTF8'
})).map(JSON.parse).filter(identity).map(wrapAction).map(parseAction).catch(() => Observable.empty());
encoding: 'UTF8'
}))
.map(JSON.parse).filter(identity).map(wrapAction).map(parseAction).catch(() => Observable.empty());
};

export default createFallback$;
2 changes: 1 addition & 1 deletion src/store.js
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@ const createStore = (node$, indexer) => {
}));

let store = null;
const storeReady = store$.take(1).do(_store => {
const storeReady = store$.take(1).do(_store => {
store = _store;
}).toPromise();
const observable = store$.do(_store => {
Expand Down
25 changes: 16 additions & 9 deletions src/test/etcd.js
Original file line number Diff line number Diff line change
Expand Up @@ -21,21 +21,28 @@ test('should composite events observable', async t => {
});
const watcher$ = createEtcd$(client, client.watcher(), '/');

const expected = [{
const expected = [
{
action: 'get',
node: {
key: '/',
dir: true,
nodes: [setEvent.node]
}
}, setEvent, deleteEvent, {
action: 'get',
node: {
key: '/',
dir: true,
nodes: []
}
}, deleteEvent, setEvent];
},
setEvent,
deleteEvent,
{
action: 'get',
node: {
key: '/',
dir: true,
nodes: []
}
},
deleteEvent,
setEvent
];

const events = await watcher$.take(6).toArray().toPromise();
t.deepEqual(events, expected);
Expand Down
20 changes: 10 additions & 10 deletions src/test/patch.js
Original file line number Diff line number Diff line change
Expand Up @@ -222,16 +222,16 @@ test('should remove folder', t => {
key: '/foo/foo'
},
prevNode: {
key: '/foo/foo',
dir: true,
nodes: [{
key: '/foo/foo/foo',
value: 'foo'
}, {
key: '/foo/foo/bar',
value: 'bar'
}]
}
key: '/foo/foo',
dir: true,
nodes: [{
key: '/foo/foo/foo',
value: 'foo'
}, {
key: '/foo/foo/bar',
value: 'bar'
}]
}
};

const output = {
Expand Down

0 comments on commit 346c615

Please sign in to comment.