Compare commits
No commits in common. "0fed1a245164701be55f64b499c05a790d0e5128" and "5d5ee9c644d44c4736ab24523ff37bbf633825b4" have entirely different histories.
0fed1a2451
...
5d5ee9c644
@ -37,11 +37,6 @@ func AdaptA(underlying net.Conn, party Party) Conn {
|
||||
transChan: make(chan *transA),
|
||||
done: make(chan struct { }),
|
||||
}
|
||||
if party == ClientSide {
|
||||
conn.transID = 1
|
||||
} else {
|
||||
conn.transID = -1
|
||||
}
|
||||
go conn.receive()
|
||||
return conn
|
||||
}
|
||||
@ -65,7 +60,6 @@ func (this *a) OpenTrans() (Trans, error) {
|
||||
id := this.transID
|
||||
this.transID ++
|
||||
trans := &transA {
|
||||
parent: this,
|
||||
id: id,
|
||||
incoming: usync.NewGate[incomingMessage](),
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user