Streams for reactive microservices