Functional reactive client responds to socket stream