ssbc / go-ssb

Go implementation of ssb (work in progress!)
https://scuttlebutt.nz
160 stars 26 forks source link

Remove usage of PushSource? #304

Open decentral1se opened 1 year ago

decentral1se commented 1 year ago

Companion ticket for https://github.com/ssbc/go-luigi/issues/5.

Seems like it's not used much?

grep -iR "PushSource" . ./cmd/ssb-truncate-log/truncate.go: err = src.(luigi.PushSource).Push(context.TODO(), luigi.FuncSink(func(ctx context.Context, v interface{}, err error) error { ./cmd/ssb-logcat/main.go: err = src.(luigi.PushSource).Push(context.TODO(), luigi.FuncSink(func(ctx context.Context, v interface{}, err error) error {