Skip to content

Commit 39cc04d

Browse files
committed
fix: make startPolling private
1 parent 00021bb commit 39cc04d

2 files changed

Lines changed: 3 additions & 3 deletions

File tree

pkg/timelock/worker_solana.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -120,7 +120,7 @@ func (w *WorkerSolana) Listen(ctx context.Context) error {
120120
schedulingDone := w.scheduler.runScheduler(ctxwc)
121121

122122
//// Retrieve logs asynchronously.
123-
pollDone, txCh := w.StartPolling(ctxwc)
123+
pollDone, txCh := w.startPolling(ctxwc)
124124

125125
// Start processing transactions
126126
procDone := w.processTransactions(ctxwc, txCh)
@@ -148,7 +148,7 @@ func (w *WorkerSolana) Listen(ctx context.Context) error {
148148
return nil
149149
}
150150

151-
func (w *WorkerSolana) StartPolling(ctx context.Context) (<-chan struct{}, <-chan *rpc.TransactionWithMeta) {
151+
func (w *WorkerSolana) startPolling(ctx context.Context) (<-chan struct{}, <-chan *rpc.TransactionWithMeta) {
152152
done := make(chan struct{})
153153
txCh := make(chan *rpc.TransactionWithMeta, w.pollSize)
154154
sigCh := make(chan solana.Signature, 100)

pkg/timelock/worker_solana_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -166,7 +166,7 @@ func TestStartPolling(t *testing.T) {
166166
ctx, cancel := context.WithTimeout(t.Context(), 2*time.Second)
167167
defer cancel()
168168

169-
done, ch := w.StartPolling(ctx)
169+
done, ch := w.startPolling(ctx)
170170

171171
got := assertExpectedTransactions(t, ch, done, ctx, tc.txResponses)
172172

0 commit comments

Comments
 (0)