git ssb

1
const EventEmitter = require('events')
2
3
module.exports = class Port extends EventEmitter {
4
  constructor () {
5
    super()
6
    this.queue = []
7
  }
8
9
  connect (destPort) {
10
    this.destPort = destPort
11
    destPort.destPort = this
12
  }
13
14
  async send (message) {
15
    return this.destPort.recieve(message)
16
  }
17
18
  async recieve (message) {
19
    this.emit('message', message)
20
    this.queue.push(message)
21
  }
22
23
  dequeue () {
24
    return this.queue.unshift()
25
  }
26
}
27