[FLINK-1173] Add unit test for SocketTextStreamFunction