Skip to content

Commit

Permalink
call internal drain from chotki
Browse files Browse the repository at this point in the history
  • Loading branch information
Termina1 committed Nov 26, 2024
1 parent 28b5475 commit c58bf2e
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions chotki.go
Original file line number Diff line number Diff line change
Expand Up @@ -277,7 +277,7 @@ func Open(dirname string, opts Options) (*Chotki, error) {
protocol.Record('S', rdx.Stlv("")),
))

if err = cho.Drain(context.Background(), init); err != nil {
if err = cho.drain(context.Background(), init); err != nil {
return nil, errors.Join(err, fmt.Errorf("unable to drain initial data to chotki"))
}
}
Expand Down Expand Up @@ -506,7 +506,7 @@ func (cho *Chotki) CommitPacket(ctx context.Context, lit byte, ref rdx.ID, body
r := protocol.Record('R', ref.ZipBytes())
packet := protocol.Record(lit, i, r, protocol.Join(body...))
recs := protocol.Records{packet}
err = cho.Drain(ctx, recs)
err = cho.drain(ctx, recs)
cho.Broadcast(ctx, recs, "")
return
}
Expand Down

0 comments on commit c58bf2e

Please sign in to comment.