broker

type Broker interface {
	SubscribeNewHeads(chan event.Block) Subscription
	SubscribeLogs(request.LogSubscriptionOptions, chan event.Logs) Subscription
	UnsubscribeFromNewHeads(Subscription)
	UnsubscribeFromLogs(Subscription)
	PublishNewHeads(event.Block)
	PublishLogs(event.Logs)
}

type SubID string

type Subscription interface {
	GetId() SubID
	GetNewHeadsCh() chan event.Block
	GetLogsCh() chan event.Logs
	GetLogsSubOpts() request.LogSubscriptionOptions
}