Skip to content
This repository was archived by the owner on Jun 27, 2023. It is now read-only.
Merged
Show file tree
Hide file tree
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
chore: clarify iterable stream
  • Loading branch information
wemeetagain committed Jul 16, 2020
commit 20c62b18e4bec1b13da864dcb18096afac15b98f
2 changes: 1 addition & 1 deletion src/index.js
Original file line number Diff line number Diff line change
Expand Up @@ -168,7 +168,7 @@ class PubsubBaseProtocol extends EventEmitter {
* @private
* @param {Object} props
* @param {string} props.protocol
* @param {Stream} props.stream
* @param {DuplexIterableStream} props.stream
* @param {Connection} props.connection connection
*/
_onIncomingStream ({ protocol, stream, connection }) {
Expand Down
8 changes: 4 additions & 4 deletions src/peerStreams.js
Original file line number Diff line number Diff line change
Expand Up @@ -35,13 +35,13 @@ class PeerStreams extends EventEmitter {
/**
* The raw outbound stream, as retrieved from conn.newStream
* @private
* @type {Stream}
* @type {DuplexIterableStream}
*/
this._rawOutboundStream = null
/**
* The raw inbound stream, as retrieved from the callback from libp2p.handle
* @private
* @type {Stream}
* @type {DuplexIterableStream}
*/
this._rawInboundStream = null
/**
Expand All @@ -57,7 +57,7 @@ class PeerStreams extends EventEmitter {
this.outboundStream = null
/**
* Read stream
* @type {Stream}
* @type {DuplexIterableStream}
*/
this.inboundStream = null
}
Expand Down Expand Up @@ -99,7 +99,7 @@ class PeerStreams extends EventEmitter {
/**
* Attach a raw inbound stream and setup a read stream
*
* @param {Stream} stream
* @param {DuplexIterableStream} stream
* @returns {void}
*/
attachInboundStream (stream) {
Expand Down