js-libp2p stream

stream.js

const ROLE = {
  INITIATOR: 0,
  RESPONDER: 1
}

class Stream {
  constructor(iterableDuplex, connection, isInitiator = true) {
    /**
     * Stream identifier
     */
    this.id = (~~(Math.random() * 1e9)).toString(36) + Date.now()

    /** 
     * Streaming iterable duplex object
     */
    this._iterableDuplex = iterableDuplex

    /**
     * Stream parent connection
     */
    this.connection = connection

    /**
     * Role in the stream, initiator or responder
     */
    this.role = isInitiator ? ROLE.INITIATOR : ROLE.RESPONDER

    /** 
     * Stream timeline
     */
    this.timeline = {
      openTs: Date.now(),
      closeTs: undefined
    }

    /**
     * User provided tags
     */
    this.tags = []

    /** 
     * Stream protocol
     */
    this._protocol = undefined
  }

  sink () {

  }

  source () {

  }

  close () {

  }
}

@alanshaw do you envision sink and source as you have in js-libp2p-websockets?

https://github.com/libp2p/js-libp2p-websockets/pull/82/files#diff-1fdf421c05c1140f6d71444ea2b27638R47

In this case, we need to pass the options to this stream class for the abortable, and in newStream for the connection.