func NewCrosslinkStream(trackingShard uint64, cb func(c *primitives.Crosslink)) *CrosslinkStream {
	return &CrosslinkStream{
		trackingShard: trackingShard,
		callback: cb,
	}
}
// NewCrosslinkStream tracks a new shard with the given callback.
NewCrosslinkStream tracks a new shard with the given callback.
// NewCrosslinkStream tracks a new shard with the given callback .
func NewCrosslinkStream(trackingShard uint64, cb func(c *primitives.Crosslink)) *CrosslinkStream {
	return &CrosslinkStream{
		trackingShard: trackingShard,
		callback: cb,
	}
}
func NewCrosslinkStream ( trackingShard uint64 , cb func ( c * primitives . Crosslink ) ) * CrosslinkStream { return & CrosslinkStream { trackingShard : trackingShard , callback : cb , } }
NewCrosslinkStream tracks a new shard with the given callback.
NewCrosslinkStream tracks a new shard with the given callback .