Skip to content

Commit

Permalink
add flow control comment to code
Browse files Browse the repository at this point in the history
  • Loading branch information
aeh committed Feb 22, 2019
1 parent c6e73e2 commit 56bb736
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions src/amqp-writable-stream.js
Original file line number Diff line number Diff line change
@@ -1,6 +1,9 @@
const { Writable } = require('stream');
const stringify = require('json-stringify-safe');

/**
* @see http://www.squaremobius.net/amqp.node/channel_api.html#flowcontrol
*/
module.exports = class AmqpWritableStream extends Writable {
constructor (channel, queueName, opts = {}) {
super(Object.assign(opts, { objectMode: true }));
Expand Down

0 comments on commit 56bb736

Please sign in to comment.