Home
last modified time | relevance | path

Searched refs:TSocketState (Results 1 – 7 of 7) sorted by relevance

/thrift-3.4.0/lib/dart/lib/src/console/
Dt_tcp_socket.dart28 final StreamController<TSocketState> _onStateController;
30 Stream<TSocketState> get onState => _onStateController.stream;
62 _onStateController.add(TSocketState.OPEN);
72 _onStateController.add(TSocketState.CLOSED);
Dt_web_socket.dart29 final StreamController<TSocketState> _onStateController;
31 Stream<TSocketState> get onState => _onStateController.stream;
63 _onStateController.add(TSocketState.OPEN);
73 _onStateController.add(TSocketState.CLOSED);
/thrift-3.4.0/lib/dart/lib/src/browser/
Dt_web_socket.dart34 final StreamController<TSocketState> _onStateController;
36 Stream<TSocketState> get onState => _onStateController.stream;
106 _onStateController.add(TSocketState.OPEN);
119 _onStateController.add(TSocketState.CLOSED);
/thrift-3.4.0/lib/dart/lib/src/transport/
Dt_socket.dart20 enum TSocketState { CLOSED, OPEN }
23 Stream<TSocketState> get onState;
/thrift-3.4.0/lib/dart/test/transport/
Dt_framed_transport_test.dart145 StreamController<TSocketState> stateController =
146 StreamController<TSocketState>();
168 Stream<TSocketState> get onState => stateController.stream;
Dt_socket_transport_test.dart237 final StreamController<TSocketState> _onStateController;
239 Stream<TSocketState> get onState => _onStateController.stream;
265 _onStateController.add(TSocketState.OPEN);
271 _onStateController.add(TSocketState.CLOSED);
/thrift-3.4.0/lib/cpp/src/thrift/server/
DTNonblockingServer.cpp90 enum TSocketState { SOCKET_RECV_FRAMING, SOCKET_RECV, SOCKET_SEND }; enum
134 TSocketState socketState_;