@@ -77,24 +77,30 @@ public void workWithAcks() throws InterruptedException {
7777 socket .on (Socket .EVENT_CONNECT , new Emitter .Listener () {
7878 @ Override
7979 public void call (Object ... objects ) {
80- socket .on ("ack" , args -> {
81- Ack fn = (Ack ) args [0 ];
82- JSONObject data = new JSONObject ();
83- try {
84- data .put ("test" , true );
85- } catch (JSONException e ) {
86- throw new AssertionError (e );
80+ socket .on ("ack" , new Emitter .Listener () {
81+ @ Override
82+ public void call (Object ... args ) {
83+ Ack fn = (Ack ) args [0 ];
84+ JSONObject data = new JSONObject ();
85+ try {
86+ data .put ("test" , true );
87+ } catch (JSONException e ) {
88+ throw new AssertionError (e );
89+ }
90+ fn .call (5 , data );
8791 }
88- fn .call (5 , data );
8992 });
90- socket .on ("ackBack" , args -> {
91- JSONObject data = (JSONObject ) args [1 ];
92- try {
93- if ((Integer ) args [0 ] == 5 && data .getBoolean ("test" )) {
94- values .offer ("done" );
93+ socket .on ("ackBack" , new Emitter .Listener () {
94+ @ Override
95+ public void call (Object ... args ) {
96+ JSONObject data = (JSONObject )args [1 ];
97+ try {
98+ if ((Integer )args [0 ] == 5 && data .getBoolean ("test" )) {
99+ values .offer ("done" );
100+ }
101+ } catch (JSONException e ) {
102+ throw new AssertionError (e );
95103 }
96- } catch (JSONException e ) {
97- throw new AssertionError (e );
98104 }
99105 });
100106 socket .emit ("callAck" );
0 commit comments