Skip to content

Commit

Permalink
docs(jsdocs): add more details for IO
Browse files Browse the repository at this point in the history
  • Loading branch information
tusharmath committed Jul 8, 2016
1 parent 4022889 commit 83c58a6
Show file tree
Hide file tree
Showing 2 changed files with 29 additions and 29 deletions.
23 changes: 11 additions & 12 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -56,7 +56,10 @@ $ mtd --help
<a name="FILE"></a>

## FILE : <code>object</code>
Stream based utils for file manipulations
Provides wrappers over the async utils inside the
[fs module](https://nodejs.org/api/fs.html).
The wrappers take in an input stream of arguments
and returns the result of function call as another stream.

**Kind**: global namespace

Expand All @@ -72,8 +75,6 @@ Stream based utils for file manipulations
<a name="FILE.open"></a>

### FILE.open(params$) ⇒ <code>[Observable](https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/core/observable.md)</code>
Stream based for `fs.open`

**Kind**: static method of <code>[FILE](#FILE)</code>

| Param | Type |
Expand All @@ -83,7 +84,7 @@ Stream based for `fs.open`
<a name="FILE.fstat"></a>

### FILE.fstat(params$) ⇒ <code>[Observable](https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/core/observable.md)</code>
Stream based for `fs.fstat`
[https://nodejs.org/api/fs.html#fs_fs_open_path_flags_mode_callback](https://nodejs.org/api/fs.html#fs_fs_open_path_flags_mode_callback)

**Kind**: static method of <code>[FILE](#FILE)</code>

Expand All @@ -94,7 +95,7 @@ Stream based for `fs.fstat`
<a name="FILE.read"></a>

### FILE.read(params$) ⇒ <code>[Observable](https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/core/observable.md)</code>
Stream based for `fs.read`
[https://nodejs.org/api/fs.html#fs_fs_read_fd_buffer_offset_length_position_callback](https://nodejs.org/api/fs.html#fs_fs_read_fd_buffer_offset_length_position_callback)

**Kind**: static method of <code>[FILE](#FILE)</code>

Expand All @@ -105,7 +106,7 @@ Stream based for `fs.read`
<a name="FILE.write"></a>

### FILE.write(params$) ⇒ <code>[Observable](https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/core/observable.md)</code>
Stream based for `fs.write`
[https://nodejs.org/api/fs.html#fs_fs_write_fd_buffer_offset_length_position_callback](https://nodejs.org/api/fs.html#fs_fs_write_fd_buffer_offset_length_position_callback)

**Kind**: static method of <code>[FILE](#FILE)</code>

Expand All @@ -116,7 +117,7 @@ Stream based for `fs.write`
<a name="FILE.close"></a>

### FILE.close(params$) ⇒ <code>[Observable](https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/core/observable.md)</code>
Stream based for `fs.close`
[https://nodejs.org/api/fs.html#fs_fs_close_fd_callback](https://nodejs.org/api/fs.html#fs_fs_close_fd_callback)

**Kind**: static method of <code>[FILE](#FILE)</code>

Expand All @@ -127,7 +128,7 @@ Stream based for `fs.close`
<a name="FILE.truncate"></a>

### FILE.truncate(params$) ⇒ <code>[Observable](https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/core/observable.md)</code>
Stream based for `fs.truncate`
[https://nodejs.org/api/fs.html#fs_fs_truncate_path_len_callback](https://nodejs.org/api/fs.html#fs_fs_truncate_path_len_callback)

**Kind**: static method of <code>[FILE](#FILE)</code>

Expand All @@ -138,7 +139,7 @@ Stream based for `fs.truncate`
<a name="FILE.rename"></a>

### FILE.rename(params$) ⇒ <code>[Observable](https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/core/observable.md)</code>
Stream based for `fs.rename`
[https://nodejs.org/api/fs.html#fs_fs_rename_oldpath_newpath_callback](https://nodejs.org/api/fs.html#fs_fs_rename_oldpath_newpath_callback)

**Kind**: static method of <code>[FILE](#FILE)</code>

Expand All @@ -149,13 +150,11 @@ Stream based for `fs.rename`
<a name="HTTP"></a>

## HTTP : <code>object</code>
Stream based utils for HTTP request.

**Kind**: global namespace
<a name="HTTP.request"></a>

### HTTP.request(params) ⇒ <code>[Observable](https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/core/observable.md)</code>
Makes HTTP requests.
Stream based wrapper over [npm/request](https://www.npmjs.com/package/request)

**Kind**: static method of <code>[HTTP](#HTTP)</code>
**Returns**: <code>[Observable](https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/core/observable.md)</code> - multiplex stream
Expand Down
35 changes: 18 additions & 17 deletions src/IO.js
Original file line number Diff line number Diff line change
Expand Up @@ -13,78 +13,79 @@ export const toOB = cb => R.compose(
)

/**
* Stream based utils for file manipulations
* Provides wrappers over the async utils inside the
* {@link https://nodejs.org/api/fs.html fs module}.
* The wrappers take in an input stream of arguments
* and returns the result of function call as another stream.
* @namespace FILE
*/
export const FILE = R.curry((fs) => {
return {
/**
* Stream based for `fs.open`
* @function
* @memberOf FILE
* @param {external:Observable} params$
* @returns {external:Observable}
* @return {external:Observable}
*/
open: toOB(fs.open),

/**
* Stream based for `fs.fstat`
* {@link https://nodejs.org/api/fs.html#fs_fs_open_path_flags_mode_callback}
* @function
* @memberOf FILE
* @param {external:Observable} params$
* @returns {external:Observable}
* @return {external:Observable}
*/
fstat: toOB(fs.fstat),

/**
* Stream based for `fs.read`
* {@link https://nodejs.org/api/fs.html#fs_fs_read_fd_buffer_offset_length_position_callback}
* @function
* @memberOf FILE
* @param {external:Observable} params$
* @returns {external:Observable}
* @return {external:Observable}
*/
read: toOB(fs.read),

/**
* Stream based for `fs.write`
* {@link https://nodejs.org/api/fs.html#fs_fs_write_fd_buffer_offset_length_position_callback}
* @function
* @memberOf FILE
* @param {external:Observable} params$
* @returns {external:Observable}
* @return {external:Observable}
*/
write: toOB(fs.write),

/**
* Stream based for `fs.close`
* {@link https://nodejs.org/api/fs.html#fs_fs_close_fd_callback}
* @function
* @memberOf FILE
* @param {external:Observable} params$
* @returns {external:Observable}
* @return {external:Observable}
*/
close: toOB(fs.close),

/**
* Stream based for `fs.truncate`
* {@link https://nodejs.org/api/fs.html#fs_fs_truncate_path_len_callback}
* @function
* @memberOf FILE
* @param {external:Observable} params$
* @returns {external:Observable}
* @return {external:Observable}
*/
truncate: toOB(fs.truncate),

/**
* Stream based for `fs.rename`
* {@link https://nodejs.org/api/fs.html#fs_fs_rename_oldpath_newpath_callback}
* @function
* @memberOf FILE
* @param {external:Observable} params$
* @returns {external:Observable}
* @return {external:Observable}
*/
rename: toOB(fs.rename)
}
})

/**
* Stream based utils for HTTP request.
* @namespace HTTP
*/
export const HTTP = R.curry((_request) => {
Expand All @@ -99,7 +100,7 @@ export const HTTP = R.curry((_request) => {
requestHead,
select,
/**
* Makes HTTP requests.
* Stream based wrapper over {@link https://www.npmjs.com/package/request npm/request}
* @function
* @memberOf HTTP
* @param {object} params - {@link https://www.npmjs.com/package/request request} module params.
Expand Down

0 comments on commit 83c58a6

Please sign in to comment.