func (c CrosslinkStream) CrosslinkCreated(crosslink *primitives.Crosslink, shard uint64) {
	if c.trackingShard != shard {
		return
	}
	c.callback(crosslink)
}
CrosslinkCreated implements beacon.BlockchainNotifee and sends a message on the listening channel if we care about
the new crosslink.
package rpc
import (
	"github.com/phoreproject/synapse/beacon"
	"github.com/phoreproject/synapse/primitives"
)
type CrosslinkStream struct {
	trackingShard uint64
	callback func(c *primitives.Crosslink)
}
func NewCrosslinkStream(trackingShard uint64, cb func(c *primitives.Crosslink)) *CrosslinkStream {
	return &CrosslinkStream{
		trackingShard: trackingShard,
		callback: cb,
	}
}
func (CrosslinkStream) ConnectBlock(*primitives.Block) {}