kkrtpsi

Dec 7, 2021

Changes in this version

+ func EncodingsRead(r io.Reader, u *[cuckoo.Nhash]uint64) error

+ func EncodingsWrite(w io.Writer, u [cuckoo.Nhash]uint64) error

+ type Receiver struct

+ func NewReceiver(rw io.ReadWriter) *Receiver

+ func (r *Receiver) Intersect(ctx context.Context, n int64, identifiers <-chan []byte) (intersection [][]byte, err error)

+ type Sender struct

+ func NewSender(rw io.ReadWriter) *Sender

+ func (s *Sender) Send(ctx context.Context, n int64, identifiers <-chan []byte) (err error)