-
Notifications
You must be signed in to change notification settings - Fork 27
Conversation
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks, this looks good!
I am merging it into the other PR to test it against libp2p and fix the connection status + pubsub stream in there
@@ -1,7 +1,12 @@ | |||
'use strict' | |||
|
|||
module.exports = { | |||
const STATUS = { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This seems to be causing issues integrating with libp2p PR
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
"Property 'OPEN' does not exist on type 'typeof import("/Users/vsantos/work/pl/gh/libp2p/js-libp2p-interfaces/dist/src/connection/status")'"
Using:
const ConnectionStatus = require('libp2p-interfaces/src/connection/status')
ConnectionStatus.OPEN
@@ -243,6 +243,7 @@ class PubsubBaseProtocol extends EventEmitter { | |||
try { | |||
const { stream, protocol } = await conn.newStream(this.multicodecs) | |||
const peer = this._addPeer(peerId, protocol) | |||
// @ts-ignore MuxedStream is not DuplexIterableStream |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I will address this after merging. This should really be using the muxedStream
I end up fixing bunch of issues that were appearing in #74 when type-checking with new aegir.