func (s *Server) EventSubscription(stream pbEvent.Event_EventSubscriptionServer) error {
log.Println("Started stream")
var length int
length = len(global.TestStrings)
for {
TestStrings := global.TestStrings
if len(TestStrings) > length {
response := &pbEvent.EventResponse{
Id: TestStrings[length].Id,
Value: TestStrings[length].Value,
Key: TestStrings[length].Key,
}
if err := stream.Send(response); err != nil {
log.Println(err)
} else {
log.Println("send...")
//global.TestStrings = append(global.TestStrings[:0], global.TestStrings[1:]...)
length++
}
}
}