We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent c86a68c commit d90c1efCopy full SHA for d90c1ef
lib/src/network/connection.dart
@@ -56,9 +56,8 @@ class _Connection {
56
Socket.connect(serverConfig.host, serverConfig.port).then((Socket _socket) {
57
// Socket connected.
58
socket = _socket;
59
- _repliesSubscription = socket
60
- .transform(MongoMessageHandler().transformer)
61
- .listen(_receiveReply,
+ _repliesSubscription =
+ MongoMessageHandler().transformer.bind(socket).listen(_receiveReply,
62
onError: (e, st) {
63
_log.severe("Socket error ${e} ${st}");
64
//completer.completeError(e);
0 commit comments