diff --git a/rpc/rpc.go b/rpc/rpc.go index bcc0826f..e9a06596 100644 --- a/rpc/rpc.go +++ b/rpc/rpc.go @@ -10,7 +10,7 @@ import ( "capnproto.org/go/capnp/v3" "capnproto.org/go/capnp/v3/exc" - "capnproto.org/go/capnp/v3/exp/mpsc" + "capnproto.org/go/capnp/v3/exp/spsc" "capnproto.org/go/capnp/v3/internal/syncutil" "capnproto.org/go/capnp/v3/rpc/transport" rpccp "capnproto.org/go/capnp/v3/std/capnp/rpc" @@ -87,7 +87,7 @@ type Conn struct { closing bool // used to make shutdown() idempotent closed chan struct{} // closed when shutdown() returns - sender *mpsc.Queue[asyncSend] + sender spsc.Queue[asyncSend] // Tables questions []*question @@ -144,7 +144,7 @@ func NewConn(t Transport, opts *Options) *Conn { bgcancel: cancel, answers: make(map[answerID]*answer), imports: make(map[importID]*impent), - sender: mpsc.New[asyncSend](), + sender: spsc.New[asyncSend](), } if opts != nil { c.bootstrap = opts.BootstrapClient