RxPortal; SetAccepted (#132)

openziti · Aug 26, 2021 · 6afbacb · 6afbacb
1 parent 8572db4
commit 6afbacb
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/rxportal.go b/rxportal.go
@@ -53,6 +53,10 @@ func NewRxPortal(transport Transport, txp *TxPortal, seq *util.Sequence, closer
 	return rxp
 }
 
+func (rxp *RxPortal) SetAccepted(accepted int32) {
+	rxp.accepted = accepted
+}
+
 func (rxp *RxPortal) Read(p []byte) (int, error) {
 preread:
 	for {