Merge pull request #25 from RikitoNoto/release/1.3.3

Release/1.3.3

CHANGELOG.md

@@ -10,3 +10,5 @@ change links in README.md to github repository, and change logo size.
 change the folder name of exsample to example.
 ### 1.3.2
 fix didn't call close method.
+### 1.3.3
+fix didn't call close method of stream.

lib/tcp.dart

@@ -46,6 +46,7 @@ class Tcp implements Communicator<Socket, SocketConnectionPoint> {
   final Map<Socket, CommunicateDataTcp> _receiveBuffers = {};
   final List<Socket> _connection = [];
   final List<ServerSocket> _servers = [];
+  final List<StreamController> _streams = [];
 
   @override
   Future<Socket> connect(SocketConnectionPoint connectionPoint) async {
@@ -63,6 +64,10 @@ class Tcp implements Communicator<Socket, SocketConnectionPoint> {
     for(ServerSocket server in _servers){
       await server.close();
     }
+
+    for(StreamController controller in _streams){
+      await controller.close();
+    }
   }
 
   @override
@@ -77,6 +82,7 @@ class Tcp implements Communicator<Socket, SocketConnectionPoint> {
       SocketConnectionPoint bind) async {
     final StreamController<CommunicateData<Socket>> controller =
         StreamController();
+    _streams.add(controller);
     ServerSocket serverSocket = await _bind(bind.address, bind.port);
     _servers.add(serverSocket);
     // connection

pubspec.yaml

@@ -1,6 +1,6 @@
 name: camel
 description: A Flutter package for communicating in a local network.
-version: 1.3.2
+version: 1.3.3
 homepage:
 
 environment: