TCP Socket

https://github.com/kyorohiro/hello_skyengine/tree/master/dartio_tcp

// following code is checked in 2016/01/13
import 'package:flutter/widgets.dart';
import 'dart:io';
import 'dart:convert';
import 'dart:async';
main() async {
EchoServer echo = new EchoServer();
echo.startServer("0.0.0.0", 28080);
HelloClient hello = new HelloClient();
String te = await hello.sendHello("0.0.0.0", 28080);
Text t = new Text("#${te}#");
Center c = new Center(child: t);
runApp(c);
}
class HelloClient {
Future<String> sendHello(String address, int port) async {
Socket socket = await Socket.connect(address, port);
socket.add(UTF8.encode("hello!!"));
List<int> buffer = [];
await for (List<int> v in socket.asBroadcastStream()) {
buffer.addAll(v);
if (buffer.length >= 7) {
break;
}
}
return UTF8.decode(buffer);
}
}
class EchoServer {
ServerSocket server = null;
startServer(String address, int port) async {
server = await ServerSocket.bind(address, port);
server.listen((Socket socket) async {
await for (List<int> d in socket.asBroadcastStream()) {
socket.add(d);
}
socket.close();
});
}
bye() async {
server.close();
}
}