multi

Documentation

Index

• func Firehose(c context.T, cancel context.F, wait *sync.WaitGroup, ...)

Functions

func Firehose

func Firehose(
	c context.T,
	cancel context.F,
	wait *sync.WaitGroup,
	nostrRelays, blueskyEndpoints, farcasterHubs []string,
	fn func(bundle *types.BundleItem) (err error),
)

Firehose runs concurrent connections capturing new events appearing on each of the social network protocols, and calls a closure that provides access to the bundle formatted from a protocol event.