File tree Expand file tree Collapse file tree 1 file changed +4
-3
lines changed Expand file tree Collapse file tree 1 file changed +4
-3
lines changed Original file line number Diff line number Diff line change @@ -100,9 +100,7 @@ test!(test_monitor_events, {
100100 client. connect( "tcp://127.0.0.1:9998" ) . unwrap( ) ;
101101 bounce( & mut client, & mut server) ;
102102
103- // Close client and server
104103 close_zero_linger( client) ;
105- close_zero_linger( server) ;
106104
107105 // Now collect and check events from both sockets
108106 let mut event = get_monitor_event( & mut client_mon) . unwrap( ) ;
@@ -114,7 +112,6 @@ test!(test_monitor_events, {
114112 if version_ge_4_3( ) {
115113 expect_event( & mut client_mon, zmq:: SocketEvent :: HANDSHAKE_SUCCEEDED ) ;
116114 }
117-
118115 expect_event( & mut client_mon, zmq:: SocketEvent :: MONITOR_STOPPED ) ;
119116
120117 // This is the flow of server events
@@ -124,6 +121,10 @@ test!(test_monitor_events, {
124121 if version_ge_4_3( ) {
125122 expect_event( & mut server_mon, zmq:: SocketEvent :: HANDSHAKE_SUCCEEDED ) ;
126123 }
124+ expect_event( & mut server_mon, zmq:: SocketEvent :: DISCONNECTED ) ;
125+
126+ close_zero_linger( server) ;
127+
127128 expect_event( & mut server_mon, zmq:: SocketEvent :: CLOSED ) ;
128129 expect_event( & mut server_mon, zmq:: SocketEvent :: MONITOR_STOPPED ) ;
129130
You can’t perform that action at this time.
0 commit comments